# KubeMQ Developer Center > KubeMQ is a Kubernetes-native message broker that ships as a single binary with no external dependencies. It supports four messaging patterns — Events, Events Store, Queues, and RPC (Commands & Queries) — over gRPC, REST, and WebSocket, with official SDKs for 10 languages (Go, Python, Node.js, Java, C#, Kotlin, C++, Rust, Ruby, and Elixir) plus a language-agnostic REST API, drop-in wire connectors for Kafka, RabbitMQ (AMQP 0-9-1), AMQP 1.0, AWS SQS/SNS, Google Cloud Pub/Sub, MQTT, and STOMP, and HTTP gateways for A2A, MCP, and CloudEvents. How to use these docs as an agent: every page has a clean Markdown twin at `/llms.mdx/docs//content.md` — fetch the specific page you need from the index below rather than pulling the whole `/llms-full.txt` dump. # Documentation - Deploy - [Deploy KubeMQ](/docs/deploy): One broker that replaces your messaging stack and runs your AI-agent fabric — pick your path and install in minutes. - [Quickstart](/docs/deploy/quickstart): Run KubeMQ, open the dashboard, and round-trip your first message from the terminal — the ~5-minute universal win. - [Drive KubeMQ from the terminal](/docs/deploy/cli): Install the kmq CLI, connect to a running server, send your first message, and teach your coding agent to drive KubeMQ. - [Get a License Key](/docs/deploy/license-key): Obtain the free license token a standalone KubeMQ server needs to start, and pass it to Docker, Compose, or Helm. - [Install KubeMQ with Docker](/docs/deploy/docker): Run KubeMQ under Docker in depth — Compose, configuration, connectors, persistence, health checks, upgrade and backup. - [Install KubeMQ with Helm](/docs/deploy/kubernetes-helm): Deploy KubeMQ to Kubernetes for production with the Helm charts and operator, with a production readiness checklist. - Scenarios - Replace your messaging stack - [Replace your messaging stack](/docs/deploy/scenarios/replace): Point your existing Kafka, RabbitMQ, SQS/SNS, MQTT, STOMP, AMQP, or Pub/Sub client at KubeMQ by changing one connection string. - [Replace Kafka with KubeMQ](/docs/deploy/scenarios/replace/replace-kafka): Repoint your Kafka clients at KubeMQ's drop-in broker — enable the connector, change bootstrap.servers, verify with kcat. - [Replace RabbitMQ with KubeMQ](/docs/deploy/scenarios/replace/replace-rabbitmq): Get your RabbitMQ (AMQP 0-9-1) app running on KubeMQ in three steps — enable the connector, swap the connection string, verify. - [Replace AWS SQS & SNS with KubeMQ](/docs/deploy/scenarios/replace/replace-sqs-sns): Point your AWS SDK or LocalStack-style endpoint at KubeMQ's drop-in SQS/SNS connector — no rewrite; verify with the aws CLI or boto3. - [Replace MQTT with KubeMQ](/docs/deploy/scenarios/replace/replace-mqtt): Change your MQTT broker host to KubeMQ's drop-in connector — 3.1.1 and 5.0 clients connect unchanged; verify with mosquitto. - [Replace Google Cloud Pub/Sub with KubeMQ](/docs/deploy/scenarios/replace/replace-gcp-pubsub): Point an unmodified Pub/Sub client at KubeMQ by setting PUBSUB_EMULATOR_HOST — enable the connector and verify. - [Replace STOMP with KubeMQ](/docs/deploy/scenarios/replace/replace-stomp): Get your STOMP app running on KubeMQ in three steps — enable the connector, change the broker host, verify. - [Replace JMS, ActiveMQ, or AMQP 1.0 with KubeMQ](/docs/deploy/scenarios/replace/replace-amqp-1-0): Move JMS, ActiveMQ (Java), or native AMQP 1.0 clients onto KubeMQ's one AMQP 1.0 connector — per-client on-ramps and verification. - AI-agent fabric - [Build on the AI-agent fabric](/docs/deploy/scenarios/agents): KubeMQ's A2A and MCP gateways are live the moment it runs — connect an MCP host, register an agent, or drive it from an LLM. - [Connect an MCP host](/docs/deploy/scenarios/agents/connect-mcp-host): Point Claude Desktop, Cursor, or any MCP host at KubeMQ's built-in MCP endpoint, list the tools, and drive messaging from your LLM. - [Register your first agent](/docs/deploy/scenarios/agents/register-first-agent): Wrap an existing plain-HTTP service as a KubeMQ A2A agent with zero SDK — register, discover by capability, and invoke it. - [Drive KubeMQ from an LLM](/docs/deploy/scenarios/agents/drive-from-llm): Orchestrate durable messaging and A2A agents from an LLM over MCP in a single session — the end-to-end fabric in action. - Configure - [Configure KubeMQ](/docs/configure): Configure the KubeMQ server for your environment — Docker and Kubernetes setup, plus a full reference for every server setting. - Docker - [Docker (single-node)](/docs/configure/docker): Configure a single-node KubeMQ container — env vars, a mounted config.yaml, and the CONFIG variable; docker run and compose. - Kubernetes - [Kubernetes (Helm)](/docs/configure/kubernetes): Configure a KubeMQ cluster on Kubernetes — values.yaml, the KubemqCluster CR, interfaces, and HA. - Reference - [Configuration Reference](/docs/configure/reference): How to read the per-target tables — the legend and the cross-target gotchas. - [Core & Licensing](/docs/configure/reference/core): Core KubeMQ server settings — license key, log level, host identity, and node naming for a single instance or a clustered deployment. - [Interfaces (gRPC · REST · API · HTTP)](/docs/configure/reference/interfaces): gRPC, REST/WebSocket, the management API + API auth, and the shared HTTP server with CORS. - [Connectors](/docs/configure/reference/connectors): Runtime settings for MCP, A2A agents, CloudEvents, and the wire-protocol connectors — MQTT, AMQP 0.9.1/1.0, STOMP, Kafka, AWS, and GCP Pub/Sub. - [Storage & Queues](/docs/configure/reference/storage-queues): Persistent store limits and retention, plus queue delivery defaults and ceilings. - [Storage Engines](/docs/configure/reference/storage-engines): The two persistence engines — legacy and next — how to choose, mode isolation, durability, compaction, and next-engine clustering. - [Security (Auth · TLS)](/docs/configure/reference/security): JWT and OIDC authentication, policy-based authorization, and TLS/mTLS. - [Observability](/docs/configure/reference/observability): OpenTelemetry traces and metrics, audit logging, and notifications. - [Deployment & High Availability](/docs/configure/reference/deployment): Kubernetes packaging — image, storage, resources, health, scheduling, Service exposure — plus replicas and standalone. - [Advanced (config.yaml-only)](/docs/configure/reference/advanced): Message-broker engine internals, Go runtime tuning, standalone clustering, and routing. - Operate - [Operate KubeMQ](/docs/operate): Run KubeMQ in production with full visibility — metrics, distributed tracing, structured logging, and audit for monitoring the messaging engine. - Observability - [Observability](/docs/operate/observability): Monitor KubeMQ end to end — Prometheus metrics, OpenTelemetry tracing, structured logs, an audit trail, the dashboard, and the management API on port 8080. - [Prometheus Metrics](/docs/operate/observability/metrics): Scrape KubeMQ's always-on Prometheus endpoint — every metric series for messaging, queues, RPC latency, cluster health, and the agent platform. - [Distributed Tracing](/docs/operate/observability/tracing): Export OpenTelemetry traces and metrics over OTLP to Jaeger, Grafana Tempo, or Datadog — samplers, span attributes, and context propagation. - [Structured Logging](/docs/operate/observability/logging): KubeMQ's JSON logs on stdout — levels, runtime level changes, the field set, and correlating log lines with traces via trace and span IDs. - [Audit Logging](/docs/operate/observability/audit): KubeMQ's CloudEvents audit trail of auth, lifecycle, and data-plane events — the event catalog, retention settings, and the REST query API. - Management API - [Management API](/docs/operate/observability/api-reference): The HTTP and WebSocket management API on port 8080 — response envelope, status codes, access control, and the full endpoint and data-model reference. - [Health & System Endpoints](/docs/operate/observability/api-reference/health-system): Liveness and readiness probes, billing, and the metrics endpoint on KubeMQ's management API, with a Kubernetes probe example. - [Stats Endpoints](/docs/operate/observability/api-reference/stats): Read-only statistics endpoints for queues, channels, clients, and events stores on the KubeMQ management API. - [Dashboard Endpoints](/docs/operate/observability/api-reference/dashboard-endpoints): Pre-aggregated snapshot endpoints that power the KubeMQ dashboard — single-node and cluster snapshots plus time-bucketed activity. - [Action Endpoint](/docs/operate/observability/api-reference/actions): The unified POST /api/request endpoint for channel management and sending or receiving messages from tooling and the dashboard. - [WebSocket Protocols](/docs/operate/observability/api-reference/websockets): Real-time KubeMQ management WebSockets — the cluster snapshot stream and the live message monitor. - [Data Models](/docs/operate/observability/api-reference/data-models): JSON schemas for the shared DTOs returned by the KubeMQ management API — snapshots, families, channels, clients, charts, and monitor transports. - [Web Dashboard](/docs/operate/web-dashboard): The embedded web dashboard on port 8080 — cluster health, per-channel throughput, clients, connectors, agents, audit, and live configuration. - [kmq CLI](/docs/operate/kmq-cli): Drive KubeMQ from the terminal with the kmq command-line client — messaging, observability, contexts, roles, and the installable agent skill. - Learn - [Messaging Patterns](/docs/learn): A learning track for messaging on KubeMQ — the fundamentals, the four patterns (Events, Events Store, Queues, RPC), then composing them into architectures. - Concepts - [Messaging Fundamentals](/docs/learn/concepts): What messaging is and why it exists — synchronous vs asynchronous communication, tight vs loose coupling, and the job a message broker does. - [Interaction Styles](/docs/learn/concepts/interaction-styles): The three shapes every messaging pattern reduces to — pub/sub fan-out, point-to-point competing consumers, and request/reply round-trips. - [Delivery Guarantees](/docs/learn/concepts/delivery-guarantees): Understand at-most-once, at-least-once, and exactly-once delivery — plus acknowledgements, redelivery, idempotency, and dead-letter queues. - [Ordering & Replay](/docs/learn/concepts/ordering-and-replay): How messaging systems preserve order, number every message with a sequence, and let late consumers replay history from any position. - [Scaling & Flow Control](/docs/learn/concepts/scaling-and-flow): Scale consumers with competing-consumer groups versus fan-out broadcast, and keep fast producers from overwhelming slow consumers with backpressure. - [Channels & Routing](/docs/learn/concepts/channels-and-routing): How messages find their destination — named channels, wildcard subscriptions, and multicast routing that fans one publish out to many channels. - Events - [Events — Real-Time Pub/Sub](/docs/learn/events): Publish and subscribe to real-time events with fire-and-forget delivery and at-most-once semantics. - [Getting Started with Events](/docs/learn/events/getting-started): Build a fire-and-forget publisher and subscriber and send your first KubeMQ event in 5 minutes — at-most-once delivery, no persistence. - Tutorials - [Publish & Subscribe](/docs/learn/events/tutorials/publish-subscribe): Learn the basic pub/sub pattern with KubeMQ Events including multiple subscribers and message metadata. - [Consumer Groups](/docs/learn/events/tutorials/consumer-groups): Distribute event processing across multiple consumers with load-balanced groups. - [Wildcard Subscriptions](/docs/learn/events/tutorials/wildcard-subscriptions): Subscribe to multiple channels using wildcard patterns for flexible event routing. - [Multicast Events](/docs/learn/events/tutorials/multicast): Publish events to multiple channels simultaneously using KubeMQ channel routing syntax. - [Stream Publishing](/docs/learn/events/tutorials/stream-publishing): Send events at high throughput using bidirectional streaming for batched delivery. - How-To Guides - [Filter Events by Tags](/docs/learn/events/how-to/filter-events): Use message tags and metadata to filter events on the subscriber side. - [Handle Slow Consumers](/docs/learn/events/how-to/handle-slow-consumers): Understand and mitigate slow consumer message drops with KubeMQ Events. - [Scale Subscribers Horizontally](/docs/learn/events/how-to/scale-subscribers): Add more subscribers to a consumer group to increase event processing capacity. - Scenarios - [Real-Time Notifications System](/docs/learn/events/scenarios/real-time-notifications): Build a real-time notification system that broadcasts order status updates to multiple services. - [Live Dashboard Data Feed](/docs/learn/events/scenarios/live-dashboard): Stream real-time metrics to a dashboard using KubeMQ Events. - [Cache Invalidation](/docs/learn/events/scenarios/cache-invalidation): Coordinate cache busts across multiple services using KubeMQ Events. - [Events Reference](/docs/learn/events/reference): Complete reference for KubeMQ Events message structure, validation rules, configuration, and error codes. - Events Store - [Events Store — Persistent Pub/Sub](/docs/learn/events-store): Publish and subscribe to persistent events with replay, retention, and durable consumer groups. - [Getting Started with Events Store](/docs/learn/events-store/getting-started): Publish persistent events and subscribe with replay in 5 minutes. - Tutorials - [Persistent Publish & Subscribe](/docs/learn/events-store/tutorials/persistent-publish-subscribe): Publish persistent events and subscribe with guaranteed delivery and replay capability. - [Replay Events from Any Point](/docs/learn/events-store/tutorials/replay-events): Subscribe to stored events using all six start positions for flexible replay. - [Durable Consumer Groups](/docs/learn/events-store/tutorials/consumer-groups): Distribute persistent event processing across consumers with automatic position tracking. - [Stream Publishing](/docs/learn/events-store/tutorials/stream-publishing): Publish persistent events at high throughput using bidirectional streaming with acknowledgment. - [Event Sourcing Pattern](/docs/learn/events-store/tutorials/event-sourcing): Implement event sourcing with KubeMQ Events Store to rebuild state from stored events. - How-To Guides - [Configure Retention](/docs/learn/events-store/how-to/configure-retention): Set time-based, size-based, or count-based retention policies for stored events. - [Resume After Disconnect](/docs/learn/events-store/how-to/resume-after-disconnect): Understand how durable subscriptions track position and resume automatically. - [Monitor Storage Utilization](/docs/learn/events-store/how-to/monitor-storage): Monitor disk usage and understand storage utilization thresholds that affect publishing. - Scenarios - [Audit Trail System](/docs/learn/events-store/scenarios/audit-trail): Build a compliance-ready audit trail using KubeMQ Events Store for immutable event logging. - [Event-Driven State Machine](/docs/learn/events-store/scenarios/event-driven-state-machine): Implement an order processing state machine driven by persistent events. - [Cross-Service State Sync](/docs/learn/events-store/scenarios/cross-service-sync): Synchronize state across microservices using KubeMQ Events Store as a shared event log. - [Events Store Reference](/docs/learn/events-store/reference): Complete reference for KubeMQ Events Store message structure, start positions, storage config, and error codes. - Queues - [Queues — Point-to-Point Messaging](/docs/learn/queues): Send messages to KubeMQ queues with guaranteed delivery, acknowledgment, visibility timeout, dead letter routing, and delayed scheduling. - [Getting Started with Queues](/docs/learn/queues/getting-started): Send and receive your first KubeMQ queue message with acknowledgment in 5 minutes. - Tutorials - [Send & Receive Messages](/docs/learn/queues/tutorials/send-receive): Learn the complete queue send-receive-acknowledge cycle with metadata, tags, and error handling. - [Ack, Nack & Requeue](/docs/learn/queues/tutorials/ack-nack-requeue): Master the three message settlement options — acknowledge, negative acknowledge, and requeue to another channel. - [Dead Letter Queue](/docs/learn/queues/tutorials/dead-letter-queue): Route failed messages to a dead letter queue after exceeding the maximum receive count. - [Delayed Messages](/docs/learn/queues/tutorials/delayed-messages): Schedule messages for future delivery using KubeMQ delayed message queues. - [Batch Operations](/docs/learn/queues/tutorials/batch-operations): Send and receive multiple queue messages in a single operation for higher throughput. - [Stream API (Upstream/Downstream)](/docs/learn/queues/tutorials/stream-api): Use bidirectional streaming for continuous queue message sending and receiving. - [Peek Messages](/docs/learn/queues/tutorials/peek-messages): Inspect queue contents without consuming messages. - How-To Guides - [Configure Visibility Timeout](/docs/learn/queues/how-to/visibility-timeout): Control how long messages are hidden during processing before redelivery. - [Extend Visibility Timeout](/docs/learn/queues/how-to/extend-visibility): Extend the processing window for long-running queue operations. - [Message Expiration (TTL)](/docs/learn/queues/how-to/message-expiration): Set time-to-live for queue messages to auto-expire unprocessed items. - [Retry with Backoff](/docs/learn/queues/how-to/retry-with-backoff): Implement retry patterns with exponential backoff and dead letter queue fallback. - [Purge Queue](/docs/learn/queues/how-to/purge-queue): Purge a KubeMQ queue channel, permanently clearing all pending messages, using the REST API, CLI, or an SDK admin call. - Scenarios - [Order Processing Pipeline](/docs/learn/queues/scenarios/order-processing): Build a reliable order processing pipeline with queues, DLQ, and retry logic. - [Background Job Worker](/docs/learn/queues/scenarios/background-workers): Distribute background jobs across a pool of workers using KubeMQ queues. - [Scheduled Task System](/docs/learn/queues/scenarios/scheduled-tasks): Implement cron-like scheduled tasks using KubeMQ delayed messages. - [Reliable Webhook Delivery](/docs/learn/queues/scenarios/webhook-delivery): Guarantee webhook delivery with retry, exponential backoff, and dead letter handling. - [Queue Reference](/docs/learn/queues/reference): Complete reference for KubeMQ queue message structure, policy fields, server configuration, and error codes. - RPC - [RPC — Commands & Queries](/docs/learn/rpc): Synchronous request-reply messaging with Commands for writes and Queries for reads, following CQRS principles. - [Getting Started with RPC](/docs/learn/rpc/getting-started): Send your first KubeMQ command and query in 5 minutes. - Tutorials - [Send Commands](/docs/learn/rpc/tutorials/send-commands): Send fire-and-confirm commands with configurable timeouts and execution status. - [Send Queries](/docs/learn/rpc/tutorials/send-queries): Send queries and receive structured response data with optional server-side caching. - [Handle Commands](/docs/learn/rpc/tutorials/handle-commands): Build a command responder that processes incoming requests and sends execution status. - [Handle Queries](/docs/learn/rpc/tutorials/handle-queries): Build a query responder that processes incoming requests and returns structured data. - [Query Caching](/docs/learn/rpc/tutorials/query-caching): Enable server-side response caching for queries with configurable TTL. - [Request-Reply Roundtrip](/docs/learn/rpc/tutorials/request-reply-roundtrip): Implement the full request-reply cycle showing both sender and responder in a single example. - How-To Guides - [Configure Timeouts & Retries](/docs/learn/rpc/how-to/timeout-configuration): Set per-request timeouts and implement retry strategies for KubeMQ RPC calls. - [Load Balance Across Responders](/docs/learn/rpc/how-to/load-balancing): Distribute command and query processing across multiple responders using groups. - [Implement Circuit Breaker](/docs/learn/rpc/how-to/circuit-breaker): Protect services from cascading failures with a circuit breaker pattern for RPC calls. - Scenarios - [Service-to-Service API Gateway](/docs/learn/rpc/scenarios/api-gateway): Build a microservice API gateway using KubeMQ RPC for inter-service communication. - [CQRS Implementation](/docs/learn/rpc/scenarios/cqrs-implementation): Implement Command Query Responsibility Segregation with KubeMQ Commands and Queries. - [Device Command & Control](/docs/learn/rpc/scenarios/device-control): Send commands to IoT devices and query their status using KubeMQ RPC. - [Commands & Queries Reference](/docs/learn/rpc/reference): Complete reference for KubeMQ RPC — request/response structure, caching, timeouts, and error codes. - Guides - [Choosing a Messaging Pattern](/docs/learn/guides/choosing-a-pattern): Interactive decision guide to select the right KubeMQ messaging pattern for your use case. - [Channel Routing](/docs/learn/guides/channel-routing): Publish to multiple channels and patterns simultaneously using KubeMQ routing syntax. - [Error Handling Patterns](/docs/learn/guides/error-handling): Handle errors consistently across all KubeMQ messaging patterns. - [Connect with TLS & mTLS](/docs/learn/guides/connect-with-tls): Establish secure TLS and mutual TLS connections to KubeMQ across all messaging patterns. - [OpenTelemetry Integration](/docs/learn/guides/opentelemetry): Add distributed tracing and metrics to KubeMQ messaging with OpenTelemetry. - [Channel Management](/docs/learn/guides/channel-management): Create, delete, list, and purge channels programmatically. - [Production Checklist](/docs/learn/guides/production-checklist): Checklist for deploying KubeMQ messaging in production. - Aiway - [KubeMQ Aiway](/docs/aiway): KubeMQ Aiway is an AI Agents Fabric — register, discover, invoke, and stream AI agents over an enterprise message broker; A2A and MCP are the two doors in. - AI Agents (A2A) - [AI Agents (A2A)](/docs/aiway/a2a): A JSON-RPC 2.0 gateway and agent registry that routes requests between AI agents over plain HTTP — no KubeMQ SDK on the agent. - [Getting Started](/docs/aiway/a2a/getting-started): Register an A2A agent and send your first message/send through the KubeMQ gateway in under ten minutes. - [Configuration](/docs/aiway/a2a/configuration): Configure the A2A connector — enable model, timeouts, agent TTL, concurrency, and response limits via YAML, environment variables, or Docker. - [How It Works](/docs/aiway/a2a/architecture): Inside the A2A gateway — the virtual-subscriber bridge, internal channels, header forwarding, concurrency, and cluster behavior. - **Patterns** - [Agent Registry](/docs/aiway/a2a/registry): Register, list, heartbeat, and deregister AI agents through the A2A REST API — agent cards, ownership, TTL liveness, and the MaxAgents limit. - [Agent Cards](/docs/aiway/a2a/agent-cards): Discover agent capabilities through A2A agent cards served at well-known endpoints — platform card, individual card, skills, and tags. - [Synchronous Messaging](/docs/aiway/a2a/sync-messaging): Send JSON-RPC 2.0 message/send requests to A2A agents — context IDs, custom methods, header forwarding, and concurrent calls. - [Streaming (SSE)](/docs/aiway/a2a/streaming): Stream long-running agent tasks over Server-Sent Events with message/stream — task envelopes, keepalive, idle timeout, and client-disconnect cancellation. - [Error Handling](/docs/aiway/a2a/error-handling): A2A error codes (-32001 to -32004), JSON-RPC base codes, the transport vs application error distinction, and retry strategy for AI agent calls. - Guides - [Building Agents](/docs/aiway/a2a/guides/building-agents): Build an A2A-compliant HTTP agent for KubeMQ — a plain JSON-RPC 2.0 server with no KubeMQ SDK, registered by URL via the registry. - [Authentication](/docs/aiway/a2a/guides/authentication): Secure A2A gateway and registry calls with JWT Bearer tokens — agent ownership, caller identity, and why the agent never sees your token. - [Concurrency & Limits](/docs/aiway/a2a/guides/concurrency): Per-agent concurrency caps, the 10MB response-size limit, and timeout capping that protect the A2A gateway from overload and runaway agents. - [SSE Behavior](/docs/aiway/a2a/guides/sse-behavior): Reference for the A2A Server-Sent Events wire protocol — event types, the data envelope, keepalive comments, idle timeout, and client-disconnect cancellation. - **Real-World Scenarios** - Scenarios - [Multi-Agent Gateway](/docs/aiway/a2a/scenarios/multi-agent-gateway): Run several A2A agents behind one KubeMQ gateway — register agents by skill, discover them with skill-tag filtering, and route message/send calls by agent_id. - [Streaming Task Pipeline](/docs/aiway/a2a/scenarios/streaming-task-pipeline): Drive a long-running A2A agent task with message/stream — consume task.status, task.artifact, and task.done envelopes over SSE, then cancel by disconnecting. - **Separator** - [Reference](/docs/aiway/a2a/reference): Complete A2A endpoint, JSON-RPC, agent card schema, internal channel, config, error code, and metrics reference for KubeMQ. - MCP - [MCP](/docs/aiway/mcp): Expose KubeMQ messaging and the A2A agent bridge as Model Context Protocol tools that Claude and other AI models can discover and invoke. - [Getting Started with MCP](/docs/aiway/mcp/getting-started): Run KubeMQ, connect Claude Desktop, complete the MCP JSON-RPC handshake, and call your first tool in minutes. - [Configuration](/docs/aiway/mcp/configuration): Configure the KubeMQ MCP connector — enabled by default, tool timeout, trusted origins, and the disable env var, with TOML, environment variables, and Docker. - Tools - [Tools Overview](/docs/aiway/mcp/tools): Map of all 15 KubeMQ MCP tools — 11 core messaging tools plus 4 agent-bridge tools — and the shared tools/call response shape. - [Queue Tools](/docs/aiway/mcp/tools/queues): MCP tools for durable point-to-point queue messaging — queue_send, queue_receive, and queue_peek over the tools/call method. - [Events Tools](/docs/aiway/mcp/tools/events): Publish ephemeral and persistent events and read the events store as MCP tools — events_publish, events_store_publish, and events_store_read on KubeMQ. - [Command & Query Tools](/docs/aiway/mcp/tools/commands-queries): Use the command_send and query_send MCP tools to make synchronous request/reply calls into KubeMQ from an AI model. - [Channel Management Tools](/docs/aiway/mcp/tools/channel-management): Discover KubeMQ channels through MCP — list channels by type or pattern and inspect a single channel's live metadata with channel_list and channel_info. - [Agent-bridge tools](/docs/aiway/mcp/tools/agent-bridge): Discover and message A2A agents from an MCP client with agent_list, agent_info, agent_send, and agent_query — bridging MCP to the A2A gateway. - Guides - [Client Setup](/docs/aiway/mcp/guides/client-setup): Connect any MCP client to KubeMQ — Claude Desktop config, generic JSON-RPC over HTTP, session headers, and the official SDK in nine languages. - [Authentication](/docs/aiway/mcp/guides/authentication): Secure the MCP connector with JWT Bearer tokens — attach the Authorization header to your MCP client, handle -32010 errors, and configure origin validation. - [Channel Resolution](/docs/aiway/mcp/guides/channel-resolution): How MCP tools map to KubeMQ channels — naming, the five channel types, the reserved _AGENTS_ prefix, and discovery via channel_list and channel_info. - [Session Management](/docs/aiway/mcp/guides/session-management): Establish and reuse an MCP session with the KubeMQ connector — initialize handshake, MCP-Session-Id, batch requests, and the GET /mcp keepalive stream. - [Error Handling](/docs/aiway/mcp/guides/error-handling): Detect and branch on the three MCP failure layers — HTTP/auth, JSON-RPC protocol errors, and tool isError results — and handle timeouts robustly. - Reference - [Endpoints](/docs/aiway/mcp/reference/endpoints): HTTP and JSON-RPC endpoint reference for the KubeMQ MCP connector — POST/GET /mcp, the initialize/tools/list/tools/call/ping methods, headers, and status codes. - [Tools Reference](/docs/aiway/mcp/reference/tools-reference): Complete catalog of all 15 KubeMQ MCP tools — arguments, defaults, input schemas, response shapes, and a curl example for each. - [Error Codes](/docs/aiway/mcp/reference/error-codes): Canonical error code reference for the KubeMQ MCP connector — JSON-RPC protocol codes, the auth code -32010, tool-level isError semantics, and HTTP statuses. - Tutorial - [Tutorial](/docs/aiway/tutorial): Build an AI agent fabric: register a plain-HTTP agent (no SDK), discover and invoke it, stream live results, then orchestrate it from an LLM over MCP. - [1. Set up & start KubeMQ](/docs/aiway/tutorial/setup): Start a local KubeMQ server and confirm the Aiway endpoints are live. - [2. Build & register an agent](/docs/aiway/tutorial/build-and-register-an-agent): Write a plain-HTTP Python agent — no KubeMQ SDK — and register its Agent Card with Aiway. - [3. Discover & invoke](/docs/aiway/tutorial/discover-and-invoke): Find your agent by capability and call it synchronously with message/send. - [4. Stream live results](/docs/aiway/tutorial/stream-live-results): Use message/stream to receive task.status, task.artifact, and task.done events live over SSE. - [5. Orchestrate from an LLM (MCP)](/docs/aiway/tutorial/orchestrate-from-an-llm): Connect over MCP, discover the agent with agent_list, and invoke it with agent_send — the MCP→A2A bridge in action. - [Use cases](/docs/aiway/use-cases): Where KubeMQ Aiway is uniquely strong: zero-SDK onboarding, LLM orchestration, streaming tasks, capability-based routing, and multi-tenant agent directories. - Client SDKs - [Client SDKs](/docs/sdks): Official KubeMQ client libraries for Go, Python, Node.js, Java, C#, Kotlin, C++, Rust, Ruby, and Elixir — plus the language-agnostic REST API. - Go - [Go SDK](/docs/sdks/go): Install the KubeMQ Go SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/go/tutorials): Learning-oriented, first-time lessons for the KubeMQ Go SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/go/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ Events with fire-and-forget pub/sub using the Go SDK. - [Send Command](/docs/sdks/go/tutorials/command-send): Send a KubeMQ Command and wait for the handler's execution result using the Go SDK. - [Connect](/docs/sdks/go/tutorials/connect): Establish a basic client connection to the KubeMQ server using the Go SDK as the starting point for all messaging. - [Send Your First Message](/docs/sdks/go/tutorials/first-message): Connect the Go client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/go/tutorials/persistent-pubsub): Publish and subscribe with durable message persistence using KubeMQ Events Store and the Go SDK. - [Send Query](/docs/sdks/go/tutorials/query-send): Send a KubeMQ Query and receive a data response in request-reply style using the Go SDK. - [Send & Receive](/docs/sdks/go/tutorials/send-receive): Send and receive messages on a KubeMQ queue channel with the Go SDK for basic point-to-point messaging. - How-to guides - [How-to Guides](/docs/sdks/go/how-to): Task-oriented recipes for the KubeMQ Go SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/go/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. (Go SDK). - [Close a KubeMQ Go Client](/docs/sdks/go/how-to/connection/close): Close a KubeMQ Go client connection properly to release resources and shut down cleanly. - [Custom Timeouts](/docs/sdks/go/how-to/connection/custom-timeouts): Configure connection and per-operation timeouts on the KubeMQ Go client to tune latency and failure behavior. - [Ping](/docs/sdks/go/how-to/connection/ping): Send a health-check ping with the KubeMQ Go SDK to verify server connectivity and read server information. - [Token Authentication](/docs/sdks/go/how-to/connection/token-auth): Connect to the KubeMQ server with JWT token authentication using the Go SDK to secure client access. - Error Handling - [Error Handling Examples](/docs/sdks/go/how-to/error-handling): Connection failures, graceful shutdown, and automatic reconnection. (Go SDK). - [Connection Error](/docs/sdks/go/how-to/error-handling/connection-error): Detect and handle KubeMQ connection failures gracefully with the Go SDK so your service degrades safely instead of crashing. - [Graceful Shutdown](/docs/sdks/go/how-to/error-handling/graceful-shutdown): Shut down a KubeMQ client cleanly in Go, unsubscribing and releasing resources before exit for production-safe operation. - [Reconnection](/docs/sdks/go/how-to/error-handling/reconnection): Reconnect automatically to the KubeMQ server after a disconnection using the Go SDK to keep messaging resilient. - Events - [Events Examples](/docs/sdks/go/how-to/events): Real-time fire-and-forget pub/sub: channels, subscribers, and streaming sends. (Go SDK). - [Cancel Subscription](/docs/sdks/go/how-to/events/cancel-subscription): Cancel and unsubscribe from a KubeMQ Events channel cleanly using the Go SDK. - [Consumer Group](/docs/sdks/go/how-to/events/consumer-group): Load-balance KubeMQ Events across multiple subscribers with a consumer group using the Go SDK. - [Multiple Subscribers](/docs/sdks/go/how-to/events/multiple-subscribers): Deliver the same KubeMQ Events to multiple subscribers via fan-out using the Go SDK. - [Stream Send](/docs/sdks/go/how-to/events/stream-send): Publish KubeMQ Events at high throughput by streaming sends with the Go SDK. - [Wildcard Subscription](/docs/sdks/go/how-to/events/wildcard-subscription): Subscribe to KubeMQ Events using wildcard channel patterns with the Go SDK to match many channels at once. - Events Store - [Events Store Examples](/docs/sdks/go/how-to/events-store): Persistent pub/sub with replay, consumer groups, and time-based subscriptions. (Go SDK). - [Cancel Subscription](/docs/sdks/go/how-to/events-store/cancel-subscription): Cancel and unsubscribe from a KubeMQ Events Store channel cleanly using the Go SDK. - [Consumer Group](/docs/sdks/go/how-to/events-store/consumer-group): Load-balance persistent events across subscribers with KubeMQ Events Store consumer groups using the Go SDK. - [Replay from Sequence](/docs/sdks/go/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/go/how-to/events-store/replay-from-time): Replay KubeMQ Events Store messages starting from a specific timestamp using the Go SDK. - [Start at Time Delta](/docs/sdks/go/how-to/events-store/start-at-time-delta): Subscribe to KubeMQ Events Store starting from a relative time offset using the Go SDK to replay recent events. - [Start from First](/docs/sdks/go/how-to/events-store/start-from-first): Subscribe and replay all events from the beginning - [Start from Last](/docs/sdks/go/how-to/events-store/start-from-last): Subscribe to KubeMQ Events Store starting from the most recent stored event using the Go SDK. - [Start New Only](/docs/sdks/go/how-to/events-store/start-new-only): Subscribe to only newly published KubeMQ Events Store messages, skipping history, using the Go SDK. - [Stream Send](/docs/sdks/go/how-to/events-store/stream-send): Publish persistent events at high throughput by streaming to KubeMQ Events Store with the Go SDK. - [Fan-Out](/docs/sdks/go/how-to/fan-out): Fan out messages to multiple consumers using KubeMQ Events in Go so every subscriber receives each published message. - Management - [Management Examples](/docs/sdks/go/how-to/management): Create, list, delete channels and purge queue channels programmatically. (Go SDK). - [Create Channel](/docs/sdks/go/how-to/management/create-channel): Create a KubeMQ messaging channel programmatically using the Go SDK management API. - [Delete Channel](/docs/sdks/go/how-to/management/delete-channel): Delete an existing KubeMQ messaging channel programmatically using the Go SDK management API. - [List Channels](/docs/sdks/go/how-to/management/list-channels): List all channels on the KubeMQ server with their metadata and statistics using the Go SDK management API. - [Purge Queue](/docs/sdks/go/how-to/management/purge-queue): Purge all messages from a KubeMQ queue channel programmatically using the Go SDK management API. - Observability - [Observability Examples](/docs/sdks/go/how-to/observability): OpenTelemetry tracing and metrics with the SDK. (Go SDK). - [OpenTelemetry Setup](/docs/sdks/go/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing and metrics for the KubeMQ Go SDK to observe messaging in production. - Queues - [Queues Examples](/docs/sdks/go/how-to/queues): Guaranteed delivery with simple queues and queue streaming APIs. (Go SDK). - [Ack All](/docs/sdks/go/how-to/queues/ack-all): Acknowledge all received KubeMQ queue messages at once using the Go SDK to clear them in a single call. - [Ack Range](/docs/sdks/go/how-to/queues/ack-range): Acknowledge a range of KubeMQ queue messages by sequence number using the Go SDK stream API. - [Ack & Reject](/docs/sdks/go/how-to/queues/ack-reject): Selectively acknowledge or reject individual KubeMQ queue messages using the Go SDK stream API. - [Auto Ack](/docs/sdks/go/how-to/queues/auto-ack): Automatically acknowledge received KubeMQ queue messages on delivery using the Go SDK for simple consumption. - [Batch Send](/docs/sdks/go/how-to/queues/batch-send): Send multiple KubeMQ queue messages in a single batch using the Go SDK for efficient bulk publishing. - [Dead Letter Policy](/docs/sdks/go/how-to/queues/dead-letter-policy): Configure a dead-letter policy on KubeMQ stream Queues with the Go SDK to route repeatedly failed messages. - [Dead Letter Queue](/docs/sdks/go/how-to/queues/dead-letter-queue): Route failed KubeMQ queue messages to a dead-letter queue using the Go SDK to isolate poison messages. - [Delay Policy](/docs/sdks/go/how-to/queues/delay-policy): Configure a message delay policy on KubeMQ stream Queues using the Go SDK to defer message visibility. - [Delayed Messages](/docs/sdks/go/how-to/queues/delayed-messages): Send KubeMQ queue messages with a delivery delay using the Go SDK so consumers see them only after a wait. - [Expiration Policy](/docs/sdks/go/how-to/queues/expiration-policy): Set message expiration and TTL on KubeMQ stream Queues with the Go SDK to discard stale messages automatically. - [Nack All](/docs/sdks/go/how-to/queues/nack-all): Negative-acknowledge all received KubeMQ queue messages at once using the Go SDK to requeue them. - [Peek Messages](/docs/sdks/go/how-to/queues/peek-messages): Peek at KubeMQ queue messages without consuming them using the Go SDK so they remain available for later. - [Poll Mode](/docs/sdks/go/how-to/queues/poll-mode): Pull KubeMQ queue messages on demand with polling and a wait timeout using the Go SDK. - [Requeue All](/docs/sdks/go/how-to/queues/requeue-all): Return all received KubeMQ queue messages to the queue for redelivery using the Go SDK. - [Stream Receive](/docs/sdks/go/how-to/queues/stream-receive): Receive KubeMQ queue messages via the streaming downstream API with manual ack control using the Go SDK. - [Stream Send](/docs/sdks/go/how-to/queues/stream-send): Stream messages to a KubeMQ queue channel with the Go SDK for high-throughput, ordered queue publishing. - [Request-Reply](/docs/sdks/go/how-to/request-reply): Implement synchronous request-reply over KubeMQ Commands and Queries with the Go SDK for RPC-style messaging. - RPC - [RPC Examples](/docs/sdks/go/how-to/rpc): Commands and queries: request–reply, timeouts, groups, and caching. (Go SDK). - [Command Group](/docs/sdks/go/how-to/rpc/command-group): Load-balance KubeMQ Commands across multiple handlers with a consumer group using the Go SDK. - [Handle Command](/docs/sdks/go/how-to/rpc/command-handle): Register a handler for incoming KubeMQ Commands and send replies using the Go SDK. - [Command Timeout](/docs/sdks/go/how-to/rpc/command-timeout): Handle KubeMQ Command execution timeouts when no handler responds in time using the Go SDK. - [Cached Query](/docs/sdks/go/how-to/rpc/query-cached): Enable server-side response caching for KubeMQ Queries to serve repeated requests from cache using the Go SDK. - [Query Group](/docs/sdks/go/how-to/rpc/query-group): Load-balance KubeMQ Queries across multiple handlers with a consumer group using the Go SDK. - [Handle Query](/docs/sdks/go/how-to/rpc/query-handle): Register a handler for incoming KubeMQ Queries and return response data using the Go SDK. - TLS - [TLS & mTLS Examples](/docs/sdks/go/how-to/tls): Secure connections with TLS encryption and mutual TLS authentication (Go SDK). - [mTLS Setup](/docs/sdks/go/how-to/tls/mtls-setup): Configure mutual TLS authentication for Go client connections - [TLS Setup](/docs/sdks/go/how-to/tls/tls-setup): Configure server-side TLS encryption for Go client connections - [Work Queue](/docs/sdks/go/how-to/work-queue): Distribute work across competing consumers using KubeMQ Queues in Go so each task is processed by exactly one worker. - Reference - [Reference](/docs/sdks/go/reference): Complete API reference for the KubeMQ Go SDK: client classes, messaging methods, and configuration options. - [Client](/docs/sdks/go/reference/client): Client construction, configuration, and lifecycle — KubeMQ Go SDK reference. - [Events](/docs/sdks/go/reference/events): Fire-and-forget pub/sub — KubeMQ Go SDK reference. - [Events Store](/docs/sdks/go/reference/events-store): Durable events with replay — KubeMQ Go SDK reference. - [Queues](/docs/sdks/go/reference/queues): Durable queues, polling, and streaming — KubeMQ Go SDK reference. - [RPC](/docs/sdks/go/reference/rpc): KubeMQ Go SDK reference for Commands and Queries, covering request-reply methods, timeouts, and response caching. - [Types & Errors](/docs/sdks/go/reference/types-and-errors): Shared message helpers, responses, and errors — KubeMQ Go SDK reference. - Python - [Python SDK](/docs/sdks/python): Install the KubeMQ Python SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/python/tutorials): Learning-oriented, first-time lessons for the KubeMQ Python SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/python/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ events with the Python SDK in a basic pub/sub example. - [Send Command](/docs/sdks/python/tutorials/command-send): Send a KubeMQ command and wait for an execution response from a handler using the Python SDK. - [Connect](/docs/sdks/python/tutorials/connect): Establish a basic client connection to the KubeMQ server using the Python SDK and verify it succeeds. - [Send Your First Message](/docs/sdks/python/tutorials/first-message): Connect the Python client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/python/tutorials/persistent-pubsub): Publish and subscribe to a KubeMQ Events Store channel with message persistence using the Python SDK. - [Send Query](/docs/sdks/python/tutorials/query-send): Send a KubeMQ query and receive a data response from a handler using the Python SDK. - [Send & Receive](/docs/sdks/python/tutorials/send-receive): Send and receive messages on a KubeMQ queue channel with the Python SDK in a basic round trip. - How-to guides - [How-to Guides](/docs/sdks/python/how-to): Task-oriented recipes for the KubeMQ Python SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/python/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. (Python SDK). - [Close a KubeMQ Python Client](/docs/sdks/python/how-to/connection/close): Properly close a KubeMQ Python client connection to release resources and shut down cleanly. - [Custom Timeouts](/docs/sdks/python/how-to/connection/custom-timeouts): Configure connection and per-operation timeouts on a KubeMQ Python client for predictable behavior. - [Ping](/docs/sdks/python/how-to/connection/ping): Ping the KubeMQ server with the Python SDK to verify connectivity and check server health. - [Token Authentication](/docs/sdks/python/how-to/connection/token-auth): Connect to the KubeMQ server with JWT token authentication using the Python SDK client. - Error Handling - [Error Handling Examples](/docs/sdks/python/how-to/error-handling): Connection failures, graceful shutdown, and automatic reconnection. (Python SDK). - [Connection Error](/docs/sdks/python/how-to/error-handling/connection-error): Handle KubeMQ connection failures gracefully with the Python SDK, catching errors and reporting them cleanly. - [Graceful Shutdown](/docs/sdks/python/how-to/error-handling/graceful-shutdown): Gracefully shut down a KubeMQ Python client, releasing connections and cleaning up resources on exit. - [Reconnection](/docs/sdks/python/how-to/error-handling/reconnection): Automatically reconnect a KubeMQ Python client after a dropped connection to keep messaging resilient. - Events - [Events Examples](/docs/sdks/python/how-to/events): Real-time fire-and-forget pub/sub: channels, subscribers, and streaming sends. (Python SDK). - [Cancel Subscription](/docs/sdks/python/how-to/events/cancel-subscription): Unsubscribe from a KubeMQ events channel and cancel an active subscription with the Python SDK. - [Consumer Group](/docs/sdks/python/how-to/events/consumer-group): Load-balance KubeMQ events across multiple subscribers in a consumer group using the Python SDK. - [Multiple Subscribers](/docs/sdks/python/how-to/events/multiple-subscribers): Deliver the same KubeMQ event to multiple independent subscribers at once using the Python SDK. - [Stream Send](/docs/sdks/python/how-to/events/stream-send): Publish high-throughput KubeMQ events via the streaming send API using the Python SDK. - [Wildcard Subscription](/docs/sdks/python/how-to/events/wildcard-subscription): Subscribe to multiple KubeMQ event channels at once using wildcard patterns with the Python SDK. - Events Store - [Events Store Examples](/docs/sdks/python/how-to/events-store): Persistent pub/sub with replay, consumer groups, and time-based subscriptions. (Python SDK). - [Cancel Subscription](/docs/sdks/python/how-to/events-store/cancel-subscription): Unsubscribe from a KubeMQ Events Store channel and cancel an active subscription with the Python SDK. - [Consumer Group](/docs/sdks/python/how-to/events-store/consumer-group): Load-balance persistent Events Store messages across a consumer group using the KubeMQ Python SDK. - [Replay from Sequence](/docs/sdks/python/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/python/how-to/events-store/replay-from-time): Replay KubeMQ Events Store messages from a specific timestamp using the Python SDK subscription API. - [Start at Time Delta](/docs/sdks/python/how-to/events-store/start-at-time-delta): Subscribe to a KubeMQ Events Store channel from a relative time offset using the Python SDK. - [Start from First](/docs/sdks/python/how-to/events-store/start-from-first): Subscribe and replay all events from the beginning - [Start from Last](/docs/sdks/python/how-to/events-store/start-from-last): Subscribe to a KubeMQ Events Store channel starting from the most recent stored event in Python. - [Start New Only](/docs/sdks/python/how-to/events-store/start-new-only): Subscribe to a KubeMQ Events Store channel for new events only, skipping stored history, in Python. - [Stream Send](/docs/sdks/python/how-to/events-store/stream-send): Publish high-throughput persistent events to the KubeMQ Events Store via streaming with the Python SDK. - [Fan-Out](/docs/sdks/python/how-to/fan-out): Fan out a single KubeMQ event to multiple subscribers at once using the Python SDK pub/sub API. - Management - [Management Examples](/docs/sdks/python/how-to/management): Create, list, delete channels and purge queue channels programmatically. (Python SDK). - [Create Channel](/docs/sdks/python/how-to/management/create-channel): Programmatically create a KubeMQ messaging channel by name and type using the Python SDK admin API. - [Delete Channel](/docs/sdks/python/how-to/management/delete-channel): Delete an existing KubeMQ channel by name and type using the Python SDK admin API. - [List Channels](/docs/sdks/python/how-to/management/list-channels): List all active KubeMQ channels on the server and inspect their stats using the Python SDK admin API. - [Purge Queue](/docs/sdks/python/how-to/management/purge-queue): Purge all pending messages from a KubeMQ queue channel using the Python SDK admin API. - Observability - [Observability Examples](/docs/sdks/python/how-to/observability): OpenTelemetry tracing and metrics with the SDK. (Python SDK). - [OpenTelemetry Setup](/docs/sdks/python/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing and metrics for a KubeMQ Python client to observe messaging operations. - Queues - [Queues Examples](/docs/sdks/python/how-to/queues): Guaranteed delivery with simple queues and queue streaming APIs. (Python SDK). - [Ack All](/docs/sdks/python/how-to/queues/ack-all): Acknowledge all received KubeMQ queue messages at once using the Python SDK poll API. - [Ack Range](/docs/sdks/python/how-to/queues/ack-range): Acknowledge a range of KubeMQ queue messages by sequence number using the Python SDK poll API. - [Ack & Reject](/docs/sdks/python/how-to/queues/ack-reject): Selectively acknowledge or reject individual KubeMQ queue messages using the Python SDK poll API. - [Auto Ack](/docs/sdks/python/how-to/queues/auto-ack): Automatically acknowledge received KubeMQ queue messages on delivery using the Python SDK. - [Batch Send](/docs/sdks/python/how-to/queues/batch-send): Send multiple KubeMQ queue messages in a single batch using the Python SDK for higher throughput. - [Dead Letter Policy](/docs/sdks/python/how-to/queues/dead-letter-policy): Configure a dead-letter policy on KubeMQ stream queues with the Python SDK to handle failed messages. - [Dead Letter Queue](/docs/sdks/python/how-to/queues/dead-letter-queue): Route failed KubeMQ queue messages to a dead-letter queue using the Python SDK for safe handling. - [Delay Policy](/docs/sdks/python/how-to/queues/delay-policy): Field-level reference for delay_in_seconds, the QueueMessage field that configures delivery delay in the Python SDK. - [Delayed Messages](/docs/sdks/python/how-to/queues/delayed-messages): Send KubeMQ queue messages with a delivery delay using the Python SDK to schedule future delivery. - [Expiration Policy](/docs/sdks/python/how-to/queues/expiration-policy): Set message expiration (TTL) on KubeMQ stream queues using the Python SDK to auto-expire stale messages. - [Nack All](/docs/sdks/python/how-to/queues/nack-all): Negative-acknowledge all received KubeMQ queue messages at once using the Python SDK poll API. - [Peek Messages](/docs/sdks/python/how-to/queues/peek-messages): Peek at KubeMQ queue messages without consuming them using the Python SDK to inspect queue contents. - [Poll Mode](/docs/sdks/python/how-to/queues/poll-mode): Pull KubeMQ queue messages on demand in poll mode using the Python SDK for controlled consumption. - [Requeue All](/docs/sdks/python/how-to/queues/requeue-all): Return all received KubeMQ queue messages back to the queue at once using the Python SDK poll API. - [Stream Receive](/docs/sdks/python/how-to/queues/stream-receive): Receive KubeMQ queue messages via the downstream streaming API using the Python SDK. - [Stream Send](/docs/sdks/python/how-to/queues/stream-send): Stream messages to a KubeMQ queue channel using the Python SDK upstream API for efficient sending. - [Request-Reply](/docs/sdks/python/how-to/request-reply): Implement synchronous request-reply messaging with the KubeMQ Python SDK using commands and queries. - RPC - [RPC Examples](/docs/sdks/python/how-to/rpc): Commands and queries: request–reply, timeouts, groups, and caching. (Python SDK). - [Command Group](/docs/sdks/python/how-to/rpc/command-group): Load-balance KubeMQ commands across multiple handlers in a group using the Python SDK. - [Handle Command](/docs/sdks/python/how-to/rpc/command-handle): Register a handler for incoming KubeMQ commands and send responses using the Python SDK. - [Command Timeout](/docs/sdks/python/how-to/rpc/command-timeout): Handle KubeMQ command execution timeouts when no handler responds in time using the Python SDK. - [Cached Query](/docs/sdks/python/how-to/rpc/query-cached): Use server-side query response caching for repeated KubeMQ queries with the Python SDK. - [Query Group](/docs/sdks/python/how-to/rpc/query-group): Load-balance KubeMQ queries across multiple handlers in a group using the Python SDK. - [Handle Query](/docs/sdks/python/how-to/rpc/query-handle): Register a handler for incoming KubeMQ queries and return data responses using the Python SDK. - TLS - [TLS & mTLS Examples](/docs/sdks/python/how-to/tls): Secure connections with TLS encryption and mutual TLS authentication (Python SDK). - [mTLS Setup](/docs/sdks/python/how-to/tls/mtls-setup): Configure mutual TLS authentication for Python client connections - [TLS Setup](/docs/sdks/python/how-to/tls/tls-setup): Configure server-side TLS encryption for Python client connections - [Work Queue](/docs/sdks/python/how-to/work-queue): Distribute work across competing consumers using a KubeMQ queue and the Python SDK for load balancing. - Reference - [Reference](/docs/sdks/python/reference): Complete API reference for the KubeMQ Python SDK, covering clients, queues, events, commands, and queries. - [Client](/docs/sdks/python/reference/client): Client classes and configuration — KubeMQ Python SDK reference. - [Events](/docs/sdks/python/reference/events): Fire-and-forget pub/sub — KubeMQ Python SDK reference. - [Events Store](/docs/sdks/python/reference/events-store): Durable events with replay — KubeMQ Python SDK reference. - [Queues](/docs/sdks/python/reference/queues): Durable queues, polling, and streaming — KubeMQ Python SDK reference. - [RPC](/docs/sdks/python/reference/rpc): Commands and queries — KubeMQ Python SDK reference. - [Types & Errors](/docs/sdks/python/reference/types-and-errors): Shared types and exceptions — KubeMQ Python SDK reference. - Node.js - [Node.js SDK](/docs/sdks/nodejs): Install the KubeMQ Node.js SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/nodejs/tutorials): Learning-oriented, first-time lessons for the KubeMQ Node.js SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/nodejs/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ events with the Node.js SDK for fire-and-forget pub/sub messaging across clients. - [Send Command](/docs/sdks/nodejs/tutorials/command-send): Send a KubeMQ command and wait for its execution result in Node.js using request-reply for reliable remote command invocation. - [Connect](/docs/sdks/nodejs/tutorials/connect): Establish a basic client connection to the KubeMQ server with the Node.js SDK, setting the address and client ID to start messaging. - [Send Your First Message](/docs/sdks/nodejs/tutorials/first-message): Connect the Node.js client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/nodejs/tutorials/persistent-pubsub): Publish and subscribe to a KubeMQ Events Store channel with message persistence in Node.js for durable, replayable pub/sub. - [Send Query](/docs/sdks/nodejs/tutorials/query-send): Send a KubeMQ query and receive a data response in Node.js using request-reply to fetch results from a remote handler. - [Send & Receive](/docs/sdks/nodejs/tutorials/send-receive): Send and receive messages on a KubeMQ queue channel with the Node.js SDK for basic guaranteed-delivery queue messaging. - How-to guides - [How-to Guides](/docs/sdks/nodejs/how-to): Task-oriented recipes for the KubeMQ Node.js SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/nodejs/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. (Node.js SDK). - [Close a KubeMQ Node.js Client](/docs/sdks/nodejs/how-to/connection/close): Properly close a KubeMQ client connection in Node.js, releasing sockets and resources to avoid leaks on application shutdown. - [Custom Timeouts](/docs/sdks/nodejs/how-to/connection/custom-timeouts): Configure connection and per-operation timeouts on the KubeMQ Node.js client to tune reliability under slow networks and backpressure. - [Ping](/docs/sdks/nodejs/how-to/connection/ping): Send a health-check ping to verify KubeMQ server connectivity from the Node.js SDK and inspect the returned server status details. - [Token Authentication](/docs/sdks/nodejs/how-to/connection/token-auth): Connect to the KubeMQ server using JWT token authentication with the Node.js SDK to secure client access with bearer credentials. - Error Handling - [Error Handling Examples](/docs/sdks/nodejs/how-to/error-handling): Connection failures, graceful shutdown, and automatic reconnection. (Node.js SDK). - [Connection Error](/docs/sdks/nodejs/how-to/error-handling/connection-error): Handle KubeMQ connection failures gracefully in the Node.js SDK, catching connect errors and surfacing actionable diagnostics. - [Graceful Shutdown](/docs/sdks/nodejs/how-to/error-handling/graceful-shutdown): Perform a clean KubeMQ shutdown in Node.js: cancel subscriptions, drain in-flight work, and release client resources on exit. - [Reconnection](/docs/sdks/nodejs/how-to/error-handling/reconnection): Automatically reconnect to the KubeMQ server after a disconnection using the Node.js SDK, restoring subscriptions and resuming message flow. - Events - [Events Examples](/docs/sdks/nodejs/how-to/events): Real-time fire-and-forget pub/sub: channels, subscribers, and streaming sends. (Node.js SDK). - [Cancel Subscription](/docs/sdks/nodejs/how-to/events/cancel-subscription): Cancel an active KubeMQ events subscription in Node.js, cleanly unsubscribing from a pub/sub channel and stopping delivery. - [Consumer Group](/docs/sdks/nodejs/how-to/events/consumer-group): Load-balance KubeMQ events across a consumer group of subscribers in Node.js so each event is handled by exactly one member. - [Multiple Subscribers](/docs/sdks/nodejs/how-to/events/multiple-subscribers): Deliver the same KubeMQ events to multiple independent subscribers in Node.js, fanning each message out to every listener. - [Stream Send](/docs/sdks/nodejs/how-to/events/stream-send): Publish high-throughput KubeMQ events via a streaming connection in Node.js for low-latency, low-overhead real-time pub/sub. - [Wildcard Subscription](/docs/sdks/nodejs/how-to/events/wildcard-subscription): Subscribe to KubeMQ events using wildcard channel patterns in Node.js to match many topics with a single subscription. - Events Store - [Events Store Examples](/docs/sdks/nodejs/how-to/events-store): Persistent pub/sub with replay, consumer groups, and time-based subscriptions. (Node.js SDK). - [Cancel Subscription](/docs/sdks/nodejs/how-to/events-store/cancel-subscription): Cancel an active KubeMQ Events Store subscription in Node.js, cleanly stopping persistent event delivery and freeing the stream. - [Consumer Group](/docs/sdks/nodejs/how-to/events-store/consumer-group): Load-balance persistent Events Store messages across a consumer group with the Node.js SDK so subscribers share the event stream. - [Replay from Sequence](/docs/sdks/nodejs/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/nodejs/how-to/events-store/replay-from-time): Replay KubeMQ Events Store messages from a specific timestamp with the Node.js SDK to reprocess history from a known point in time. - [Start at Time Delta](/docs/sdks/nodejs/how-to/events-store/start-at-time-delta): Subscribe to a KubeMQ Events Store channel from a relative time offset in Node.js, replaying events from the last N seconds or minutes. - [Start from First](/docs/sdks/nodejs/how-to/events-store/start-from-first): Subscribe and replay all events from the beginning - [Start from Last](/docs/sdks/nodejs/how-to/events-store/start-from-last): Subscribe to a KubeMQ Events Store channel starting from the most recent stored event using the Node.js SDK for the latest state. - [Start New Only](/docs/sdks/nodejs/how-to/events-store/start-new-only): Subscribe to a KubeMQ Events Store channel for new events only in Node.js, skipping stored history and starting from the present. - [Stream Send](/docs/sdks/nodejs/how-to/events-store/stream-send): Publish high-throughput persistent events to a KubeMQ Events Store channel via streaming with the Node.js SDK for durable delivery. - [Fan-Out](/docs/sdks/nodejs/how-to/fan-out): Fan out messages to multiple consumers over a KubeMQ pub/sub channel in Node.js, delivering every event to all active subscribers. - Management - [Management Examples](/docs/sdks/nodejs/how-to/management): Create, list, delete channels and purge queue channels programmatically. (Node.js SDK). - [Create Channel](/docs/sdks/nodejs/how-to/management/create-channel): Programmatically create a KubeMQ messaging channel with the Node.js SDK, provisioning queues or pub/sub topics ahead of traffic. - [Delete Channel](/docs/sdks/nodejs/how-to/management/delete-channel): Delete an existing KubeMQ messaging channel programmatically with the Node.js SDK to clean up unused queues and pub/sub topics. - [List Channels](/docs/sdks/nodejs/how-to/management/list-channels): List all channels on the KubeMQ server with the Node.js SDK, filtering by type to inspect active queues and pub/sub topics. - [Purge Queue](/docs/sdks/nodejs/how-to/management/purge-queue): Purge all messages from a KubeMQ queue channel with the Node.js SDK to clear a backlog and reset the queue to an empty state. - Observability - [Observability Examples](/docs/sdks/nodejs/how-to/observability): OpenTelemetry tracing and metrics with the SDK. (Node.js SDK). - [OpenTelemetry Setup](/docs/sdks/nodejs/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing and metrics for the KubeMQ Node.js SDK to export spans and instrument messaging end to end. - Queues - [Queues Examples](/docs/sdks/nodejs/how-to/queues): Guaranteed delivery with simple queues and queue streaming APIs. (Node.js SDK). - [Ack All](/docs/sdks/nodejs/how-to/queues/ack-all): Acknowledge all received KubeMQ queue messages at once in Node.js to confirm an entire batch with a single acknowledgement call. - [Ack Range](/docs/sdks/nodejs/how-to/queues/ack-range): Acknowledge a contiguous range of KubeMQ queue messages by sequence in Node.js to confirm many deliveries in a single call. - [Ack & Reject](/docs/sdks/nodejs/how-to/queues/ack-reject): Selectively acknowledge or reject individual KubeMQ queue messages in Node.js to confirm successes and discard failed deliveries. - [Auto Ack](/docs/sdks/nodejs/how-to/queues/auto-ack): Automatically acknowledge received KubeMQ queue messages in Node.js so messages are removed on delivery without manual ack calls. - [Batch Send](/docs/sdks/nodejs/how-to/queues/batch-send): Send multiple KubeMQ queue messages in a single batch with the Node.js SDK to improve throughput and reduce round trips. - [Dead Letter Policy](/docs/sdks/nodejs/how-to/queues/dead-letter-policy): Field-level reference for the maxReceiveCount and maxReceiveQueue policy fields that configure dead-letter routing in the Node.js SDK. - [Dead Letter Queue](/docs/sdks/nodejs/how-to/queues/dead-letter-queue): Handle failed KubeMQ queue messages with dead-letter routing in Node.js, diverting poison messages after retries are exhausted. - [Delay Policy](/docs/sdks/nodejs/how-to/queues/delay-policy): Field-level reference for the delaySeconds policy option that configures delivery delay in the Node.js SDK. - [Delayed Messages](/docs/sdks/nodejs/how-to/queues/delayed-messages): Send KubeMQ queue messages with a delivery delay in Node.js so consumers receive them only after the specified time elapses. - [Expiration Policy](/docs/sdks/nodejs/how-to/queues/expiration-policy): Set message expiration and TTL on KubeMQ stream queues in Node.js so stale messages are dropped before they are ever delivered. - [Nack All](/docs/sdks/nodejs/how-to/queues/nack-all): Negative-acknowledge all received KubeMQ queue messages in Node.js, rejecting an entire batch so the server can redeliver them. - [Peek Messages](/docs/sdks/nodejs/how-to/queues/peek-messages): Peek at KubeMQ queue messages without consuming them in Node.js, inspecting payloads while leaving them available for later receivers. - [Poll Mode](/docs/sdks/nodejs/how-to/queues/poll-mode): Pull KubeMQ queue messages on demand with poll mode in Node.js, fetching batches only when the consumer is ready to process them. - [Requeue All](/docs/sdks/nodejs/how-to/queues/requeue-all): Return all received KubeMQ queue messages to the queue in Node.js, requeuing an entire batch for later redelivery and retry. - [Stream Receive](/docs/sdks/nodejs/how-to/queues/stream-receive): Receive KubeMQ queue messages via a streaming connection in Node.js with per-message acknowledge, reject, and requeue control. - [Stream Send](/docs/sdks/nodejs/how-to/queues/stream-send): Stream messages to a KubeMQ queue channel with the Node.js SDK over a long-lived connection for efficient high-volume sends. - [Request-Reply](/docs/sdks/nodejs/how-to/request-reply): Implement synchronous request-reply over KubeMQ queries with the Node.js SDK, sending a request and blocking for the responder's reply. - RPC - [RPC Examples](/docs/sdks/nodejs/how-to/rpc): Commands and queries: request–reply, timeouts, groups, and caching. (Node.js SDK). - [Command Group](/docs/sdks/nodejs/how-to/rpc/command-group): Load-balance KubeMQ commands across a group of handlers in Node.js so each command is processed by one available worker. - [Handle Command](/docs/sdks/nodejs/how-to/rpc/command-handle): Register a handler for incoming KubeMQ commands in Node.js, processing each request and returning an execution result to the sender. - [Command Timeout](/docs/sdks/nodejs/how-to/rpc/command-timeout): Handle KubeMQ command execution timeouts in Node.js, detecting when no handler responds in time and failing the request cleanly. - [Cached Query](/docs/sdks/nodejs/how-to/rpc/query-cached): Send a cached KubeMQ query in Node.js, serving repeat requests from the server cache to skip the handler and cut latency. - [Query Group](/docs/sdks/nodejs/how-to/rpc/query-group): Load-balance KubeMQ queries across a group of handlers in Node.js so each query is answered by one available responder. - [Handle Query](/docs/sdks/nodejs/how-to/rpc/query-handle): Register a handler for incoming KubeMQ queries in Node.js, processing each request and returning a data response to the caller. - TLS - [TLS & mTLS Examples](/docs/sdks/nodejs/how-to/tls): Secure connections with TLS encryption and mutual TLS authentication (Node.js SDK). - [mTLS Setup](/docs/sdks/nodejs/how-to/tls/mtls-setup): Configure mutual TLS authentication for Node.js client connections - [TLS Setup](/docs/sdks/nodejs/how-to/tls/tls-setup): Configure server-side TLS encryption for Node.js client connections - [Work Queue](/docs/sdks/nodejs/how-to/work-queue): Distribute work across competing consumers with a KubeMQ queue in Node.js, load-balancing tasks so each message is processed once. - Reference - [Reference](/docs/sdks/nodejs/reference): Complete API reference for the KubeMQ Node.js SDK. - [Client](/docs/sdks/nodejs/reference/client): Factory, connection lifecycle — KubeMQ Node.js SDK reference. - [Events](/docs/sdks/nodejs/reference/events): Fire-and-forget pub/sub — KubeMQ Node.js SDK reference. - [Events Store](/docs/sdks/nodejs/reference/events-store): Durable events with replay — KubeMQ Node.js SDK reference. - [Queues](/docs/sdks/nodejs/reference/queues): Durable queues, polling, and streaming — KubeMQ Node.js SDK reference. - [RPC](/docs/sdks/nodejs/reference/rpc): Commands and queries — KubeMQ Node.js SDK reference. - [Types & Errors](/docs/sdks/nodejs/reference/types-and-errors): Factories, responses, and errors — KubeMQ Node.js SDK reference. - Java - [Java SDK](/docs/sdks/java): Install the KubeMQ Java SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/java/tutorials): Learning-oriented, first-time lessons for the KubeMQ Java SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/java/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ Events with the Java SDK in a basic fire-and-forget pub/sub workflow. - [Send Command](/docs/sdks/java/tutorials/command-send): Send a KubeMQ Command with the Java SDK and wait for the handler's execution confirmation response. - [Connect](/docs/sdks/java/tutorials/connect): Establish a basic client connection to the KubeMQ server using the Java SDK before sending or receiving messages. - [Send Your First Message](/docs/sdks/java/tutorials/first-message): Connect the Java client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/java/tutorials/persistent-pubsub): Publish and subscribe to KubeMQ Events Store channels with full message persistence using the Java SDK. - [Send Query](/docs/sdks/java/tutorials/query-send): Send a KubeMQ Query and receive a data response with the Java SDK in a synchronous request-reply exchange. - [Send & Receive](/docs/sdks/java/tutorials/send-receive): Send and receive messages on a KubeMQ Queue channel with the Java SDK in a basic producer-consumer workflow. - How-to guides - [How-to Guides](/docs/sdks/java/how-to): Task-oriented recipes for the KubeMQ Java SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/java/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. - [Close a KubeMQ Java Client](/docs/sdks/java/how-to/connection/close): Properly close a KubeMQ Java SDK client connection to release server resources and avoid leaks on shutdown. - [Custom Timeouts](/docs/sdks/java/how-to/connection/custom-timeouts): Configure custom connection and operation timeouts for the KubeMQ Java SDK client to tune reliability and latency. - [Ping](/docs/sdks/java/how-to/connection/ping): Ping the KubeMQ server with the Java SDK to verify connectivity and read server health and version details. - [Token Authentication](/docs/sdks/java/how-to/connection/token-auth): Connect to the KubeMQ server with JWT token authentication using the Java SDK for secure, authorized access. - Error Handling - [Error Handling Examples](/docs/sdks/java/how-to/error-handling): Connection failures, graceful shutdown, and automatic reconnection. - [Connection Error](/docs/sdks/java/how-to/error-handling/connection-error): Detect and handle KubeMQ connection failures gracefully in the Java SDK with proper error reporting and recovery. - [Graceful Shutdown](/docs/sdks/java/how-to/error-handling/graceful-shutdown): Gracefully shut down a KubeMQ Java SDK client, releasing connections and resources cleanly on application exit. - [Reconnection](/docs/sdks/java/how-to/error-handling/reconnection): Automatically reconnect a KubeMQ Java SDK client after a disconnection to keep messaging resilient and uninterrupted. - Events - [Events Examples](/docs/sdks/java/how-to/events): Real-time fire-and-forget pub/sub: channels, subscribers, and streaming sends. - [Cancel Subscription](/docs/sdks/java/how-to/events/cancel-subscription): Cancel an active subscription to a KubeMQ Events channel with the Java SDK and stop receiving real-time messages. - [Consumer Group](/docs/sdks/java/how-to/events/consumer-group): Load-balance real-time KubeMQ Events across a consumer group of subscribers using the Java SDK for scalable fan-in. - [Multiple Subscribers](/docs/sdks/java/how-to/events/multiple-subscribers): Have multiple subscribers receive the same real-time KubeMQ Events with the Java SDK for broadcast-style delivery. - [Stream Send](/docs/sdks/java/how-to/events/stream-send): Publish real-time KubeMQ Events at high throughput using the streaming send API in the Java SDK. - [Wildcard Subscription](/docs/sdks/java/how-to/events/wildcard-subscription): Subscribe to multiple KubeMQ Events channels at once using wildcard channel patterns with the Java SDK. - Events Store - [Events Store Examples](/docs/sdks/java/how-to/events-store): Persistent pub/sub with replay, consumer groups, and time-based subscriptions. - [Cancel Subscription](/docs/sdks/java/how-to/events-store/cancel-subscription): Cancel an active subscription to a KubeMQ Events Store channel and stop receiving persisted events in the Java SDK. - [Consumer Group](/docs/sdks/java/how-to/events-store/consumer-group): Load-balance persistent KubeMQ Events Store messages across a consumer group of subscribers using the Java SDK. - [Replay from Sequence](/docs/sdks/java/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/java/how-to/events-store/replay-from-time): Replay persisted KubeMQ Events Store messages starting from a specific timestamp using the Java SDK. - [Start at Time Delta](/docs/sdks/java/how-to/events-store/start-at-time-delta): Subscribe to a KubeMQ Events Store channel starting from a relative time offset to replay recent events in Java. - [Start from First](/docs/sdks/java/how-to/events-store/start-from-first): Subscribe and replay all events from the beginning - [Start from Last](/docs/sdks/java/how-to/events-store/start-from-last): Subscribe to a KubeMQ Events Store channel starting from the most recently stored event using the Java SDK. - [Start New Only](/docs/sdks/java/how-to/events-store/start-new-only): Subscribe to a KubeMQ Events Store channel receiving only new events and skipping stored history, using the Java SDK. - [Stream Send](/docs/sdks/java/how-to/events-store/stream-send): Publish persistent KubeMQ Events Store messages at high throughput using the streaming send API in the Java SDK. - [Fan-Out](/docs/sdks/java/how-to/fan-out): Fan out KubeMQ Events to multiple subscribers at once with the Java SDK so every consumer receives each message. - Management - [Management Examples](/docs/sdks/java/how-to/management): Create, list, delete channels and purge queue channels programmatically. - [Create Channel](/docs/sdks/java/how-to/management/create-channel): Programmatically create a KubeMQ channel of a given type using the Java SDK administration API. - [Delete Channel](/docs/sdks/java/how-to/management/delete-channel): Delete an existing KubeMQ channel by name and type using the Java SDK administration API for cleanup and management. - [List Channels](/docs/sdks/java/how-to/management/list-channels): List all active KubeMQ channels on the server with the Java SDK administration API to inspect Events, Queues, and more. - [Purge Queue](/docs/sdks/java/how-to/management/purge-queue): Purge all pending messages from a KubeMQ Queue channel using the Java SDK administration API to reset its state. - Observability - [Observability Examples](/docs/sdks/java/how-to/observability): OpenTelemetry tracing and metrics with the Java SDK. - [OpenTelemetry Setup](/docs/sdks/java/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing and metrics for the KubeMQ Java SDK to observe message flow across your services. - Queues - [Queues Examples](/docs/sdks/java/how-to/queues): Guaranteed delivery with simple queues and queue streaming APIs. - [Ack All](/docs/sdks/java/how-to/queues/ack-all): Acknowledge all received KubeMQ Queue messages at once with the Java SDK to confirm a full batch in one call. - [Ack Range](/docs/sdks/java/how-to/queues/ack-range): Selectively acknowledge specific messages from a polled batch by sequence with the Java SDK. - [Ack & Reject](/docs/sdks/java/how-to/queues/ack-reject): Selectively acknowledge or reject individual KubeMQ Queue messages with the Java SDK to control redelivery. - [Auto Ack](/docs/sdks/java/how-to/queues/auto-ack): Automatically acknowledge received KubeMQ Queue messages with the Java SDK to simplify at-most-once processing. - [Batch Send](/docs/sdks/java/how-to/queues/batch-send): Send multiple KubeMQ Queue messages in a single batch with the Java SDK to reduce round-trips and boost throughput. - [Dead Letter Policy](/docs/sdks/java/how-to/queues/dead-letter-policy): Configure a dead-letter policy on a KubeMQ Queue stream with the Java SDK to route repeatedly failed messages. - [Dead Letter Queue](/docs/sdks/java/how-to/queues/dead-letter-queue): Route repeatedly failed KubeMQ Queue messages to a dead-letter queue with the Java SDK for later inspection. - [Delay Policy](/docs/sdks/java/how-to/queues/delay-policy): Field-level reference for delayInSeconds, the QueueMessage builder option that configures delivery delay in the Java SDK. - [Delayed Messages](/docs/sdks/java/how-to/queues/delayed-messages): Send KubeMQ Queue messages with a delivery delay using the Java SDK so consumers receive them after a set interval. - [Expiration Policy](/docs/sdks/java/how-to/queues/expiration-policy): Set a message expiration TTL on a KubeMQ Queue stream with the Java SDK so stale messages are dropped automatically. - [Reject All](/docs/sdks/java/how-to/queues/nack-all): Negative-acknowledge (reject) all received KubeMQ Queue messages with the Java SDK to trigger redelivery of the full batch. - [Peek Messages](/docs/sdks/java/how-to/queues/peek-messages): Peek at messages in a KubeMQ Queue channel without consuming them using the Java SDK to inspect pending work. - [Poll Mode](/docs/sdks/java/how-to/queues/poll-mode): Pull KubeMQ Queue messages on demand with the Java SDK using poll mode for explicit, batch-controlled consumption. - [Requeue All](/docs/sdks/java/how-to/queues/requeue-all): Return all received KubeMQ Queue messages to the queue with the Java SDK so they can be redelivered to consumers. - [Stream Receive](/docs/sdks/java/how-to/queues/stream-receive): Receive KubeMQ Queue messages with the Java SDK using the downstream queue stream API for continuous consumption. - [Stream Send](/docs/sdks/java/how-to/queues/stream-send): Stream messages to a KubeMQ Queue channel using the upstream queue stream API in the Java SDK for high throughput. - [Request-Reply](/docs/sdks/java/how-to/request-reply): Implement synchronous request-reply communication over KubeMQ Commands and Queries using the Java SDK. - RPC - [RPC Examples](/docs/sdks/java/how-to/rpc): Commands and queries: request–reply, timeouts, groups, and caching. - [Command Group](/docs/sdks/java/how-to/rpc/command-group): Load-balance KubeMQ Commands across a group of handlers with the Java SDK so each command is processed once. - [Handle Command](/docs/sdks/java/how-to/rpc/command-handle): Register a handler for incoming KubeMQ Commands with the Java SDK to process requests and return execution results. - [Command Timeout](/docs/sdks/java/how-to/rpc/command-timeout): Handle KubeMQ Command execution timeouts with the Java SDK when no handler responds within the configured window. - [Cached Query](/docs/sdks/java/how-to/rpc/query-cached): Cache KubeMQ Query responses with the Java SDK using a cache key and TTL to serve repeated requests faster. - [Query Group](/docs/sdks/java/how-to/rpc/query-group): Load-balance KubeMQ Queries across a group of handlers with the Java SDK so each query is answered once. - [Handle Query](/docs/sdks/java/how-to/rpc/query-handle): Register a handler for incoming KubeMQ Queries with the Java SDK to process requests and return data responses. - TLS - [TLS & mTLS Examples](/docs/sdks/java/how-to/tls): Secure connections with TLS encryption and mutual TLS authentication. - [mTLS Setup](/docs/sdks/java/how-to/tls/mtls-setup): Configure mutual TLS authentication for Java client connections - [TLS Setup](/docs/sdks/java/how-to/tls/tls-setup): Configure server-side TLS encryption for Java client connections - [Work Queue](/docs/sdks/java/how-to/work-queue): Distribute work across competing consumers using a KubeMQ Queue in the Java SDK for scalable task processing. - Reference - [Reference](/docs/sdks/java/reference): Complete API reference for the KubeMQ Java SDK, covering Events, Events Store, Queues, Commands, Queries, and management. - [Client](/docs/sdks/java/reference/client): Client classes, builders, and lifecycle — KubeMQ Java SDK reference. - [Events](/docs/sdks/java/reference/events): Real-time pub/sub API for Events and Events Store in the KubeMQ Java SDK reference, covering publishing and subscribing. - [Events Store](/docs/sdks/java/reference/events-store): Durable events with replay — KubeMQ Java SDK reference. - [Queues](/docs/sdks/java/reference/queues): Durable queues and streaming transports — KubeMQ Java SDK reference. - [RPC](/docs/sdks/java/reference/rpc): Commands and Queries request-reply RPC API in the KubeMQ Java SDK reference, covering sending and handling requests. - [Types & Errors](/docs/sdks/java/reference/types-and-errors): Shared types, exceptions, and performance guidance — KubeMQ Java SDK reference. - C# - [C# SDK](/docs/sdks/csharp): Install the KubeMQ .NET SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/csharp/tutorials): Learning-oriented, first-time lessons for the KubeMQ C# SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/csharp/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ events using the C# SDK pub/sub API. - [Send Command](/docs/sdks/csharp/tutorials/command-send): Send a KubeMQ command and wait for the execution response using the C# SDK RPC client. - [Connect](/docs/sdks/csharp/tutorials/connect): Establish a basic client connection to the KubeMQ server using the C# SDK to start sending and receiving messages. - [Send Your First Message](/docs/sdks/csharp/tutorials/first-message): Connect the C# client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/csharp/tutorials/persistent-pubsub): Publish and subscribe to KubeMQ events store messages with persistence using the C# SDK. - [Send Query](/docs/sdks/csharp/tutorials/query-send): Send a KubeMQ query and await a typed data response using the C# SDK RPC client. - [Send & Receive](/docs/sdks/csharp/tutorials/send-receive): Send and receive messages on a KubeMQ queue channel with the C# SDK for durable point-to-point delivery. - How-to guides - [How-to Guides](/docs/sdks/csharp/how-to): Task-oriented recipes for the KubeMQ C# SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/csharp/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. (C# SDK). - [Close a KubeMQ C# Client](/docs/sdks/csharp/how-to/connection/close): Properly close a KubeMQ C# client connection to release resources and shut down cleanly. - [Custom Timeouts](/docs/sdks/csharp/how-to/connection/custom-timeouts): Configure connection and operation timeouts on a KubeMQ C# client for resilient messaging. - [Ping](/docs/sdks/csharp/how-to/connection/ping): Send a health-check ping to verify KubeMQ server connectivity and read server info using the C# SDK. - [Token Authentication](/docs/sdks/csharp/how-to/connection/token-auth): Connect to KubeMQ with JWT token authentication using the C# SDK for secure client access. - Error Handling - [Error Handling Examples](/docs/sdks/csharp/how-to/error-handling): Connection failures, graceful shutdown, and automatic reconnection. (C# SDK). - [Connection Error](/docs/sdks/csharp/how-to/error-handling/connection-error): Handle KubeMQ connection failures gracefully in the C# SDK, catching errors and recovering cleanly. - [Graceful Shutdown](/docs/sdks/csharp/how-to/error-handling/graceful-shutdown): Gracefully shut down a KubeMQ C# client, releasing connections and cleaning up resources for production reliability. - [Reconnection](/docs/sdks/csharp/how-to/error-handling/reconnection): Automatically reconnect a KubeMQ C# client after a disconnection, restoring messaging without manual intervention. - Events - [Events Examples](/docs/sdks/csharp/how-to/events): Real-time fire-and-forget pub/sub: channels, subscribers, and streaming sends. - [Cancel Subscription](/docs/sdks/csharp/how-to/events/cancel-subscription): Unsubscribe from a KubeMQ events channel and stop receiving real-time messages using the C# SDK. - [Consumer Group](/docs/sdks/csharp/how-to/events/consumer-group): Load-balance KubeMQ events across multiple subscribers in a consumer group using the C# SDK. - [Multiple Subscribers](/docs/sdks/csharp/how-to/events/multiple-subscribers): Deliver the same KubeMQ events to multiple subscribers using the C# SDK fan-out pub/sub. - [Stream Send](/docs/sdks/csharp/how-to/events/stream-send): Publish KubeMQ events at high throughput via the streaming API using the C# SDK. - [Wildcard Subscription](/docs/sdks/csharp/how-to/events/wildcard-subscription): Subscribe to KubeMQ events using wildcard channel patterns with the C# SDK for flexible routing. - Events Store - [Events Store Examples](/docs/sdks/csharp/how-to/events-store): Persistent pub/sub with replay, consumer groups, and time-based subscriptions. - [Cancel Subscription](/docs/sdks/csharp/how-to/events-store/cancel-subscription): Unsubscribe from a KubeMQ events store channel and stop receiving persistent events using the C# SDK. - [Consumer Group](/docs/sdks/csharp/how-to/events-store/consumer-group): Load-balance persistent events store messages across a consumer group of subscribers using the C# SDK. - [Replay from Sequence](/docs/sdks/csharp/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/csharp/how-to/events-store/replay-from-time): Replay KubeMQ events store messages from a specific timestamp using the C# SDK to reprocess history. - [Start at Time Delta](/docs/sdks/csharp/how-to/events-store/start-at-time-delta): Subscribe to a KubeMQ events store channel from a relative time offset using the C# SDK. - [Start from First](/docs/sdks/csharp/how-to/events-store/start-from-first): Subscribe and replay all events from the beginning - [Start from Last](/docs/sdks/csharp/how-to/events-store/start-from-last): Subscribe to a KubeMQ events store channel starting from the most recent stored event using the C# SDK. - [Start New Only](/docs/sdks/csharp/how-to/events-store/start-new-only): Subscribe to a KubeMQ events store channel for new events only, skipping stored history, with the C# SDK. - [Stream Send](/docs/sdks/csharp/how-to/events-store/stream-send): Publish persistent events at high throughput with the events store streaming API in the C# SDK. - [Fan-Out](/docs/sdks/csharp/how-to/fan-out): Fan out messages to multiple subscribers with KubeMQ events using the C# SDK pub/sub pattern. - Management - [Management Examples](/docs/sdks/csharp/how-to/management): Create, list, delete channels and purge queue channels programmatically. (C# SDK). - [Create Channel](/docs/sdks/csharp/how-to/management/create-channel): Programmatically create a KubeMQ messaging channel using the C# SDK management API. - [Delete Channel](/docs/sdks/csharp/how-to/management/delete-channel): Delete an existing KubeMQ messaging channel programmatically using the C# SDK management API. - [List Channels](/docs/sdks/csharp/how-to/management/list-channels): List all messaging channels on the KubeMQ server using the C# SDK management API. - [Purge Queue](/docs/sdks/csharp/how-to/management/purge-queue): Clear all pending messages from a KubeMQ queue channel using the C# SDK management API. - Observability - [Observability Examples](/docs/sdks/csharp/how-to/observability): OpenTelemetry tracing and metrics with the SDK. (C# SDK). - [OpenTelemetry Setup](/docs/sdks/csharp/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing and metrics for a KubeMQ C# client to observe messaging in production. - Queues - [Queues Examples](/docs/sdks/csharp/how-to/queues): Guaranteed delivery with simple queues and queue streaming APIs. - [Ack All](/docs/sdks/csharp/how-to/queues/ack-all): Acknowledge all received KubeMQ queue messages at once in a single batch using the C# SDK. - [Ack Range](/docs/sdks/csharp/how-to/queues/ack-range): Acknowledge a range of KubeMQ queue messages by sequence number using the C# SDK. - [Ack & Reject](/docs/sdks/csharp/how-to/queues/ack-reject): Selectively acknowledge or reject individual KubeMQ queue messages using the C# SDK. - [Auto Ack](/docs/sdks/csharp/how-to/queues/auto-ack): Automatically acknowledge received KubeMQ queue messages on delivery using the C# SDK. - [Batch Send](/docs/sdks/csharp/how-to/queues/batch-send): Send multiple KubeMQ queue messages in a single batch using the C# SDK for efficient delivery. - [Dead Letter Policy](/docs/sdks/csharp/how-to/queues/dead-letter-policy): Field-level reference for MaxReceiveCount and MaxReceiveQueue, the QueueMessage properties that configure dead-letter routing in the C# SDK. - [Dead Letter Queue](/docs/sdks/csharp/how-to/queues/dead-letter-queue): Route failed KubeMQ queue messages to a dead-letter queue using the C# SDK for later inspection. - [Delay Policy](/docs/sdks/csharp/how-to/queues/delay-policy): Field-level reference for DelaySeconds, the QueueMessage property that configures delivery delay in the C# SDK. - [Delayed Messages](/docs/sdks/csharp/how-to/queues/delayed-messages): Send KubeMQ queue messages with a delivery delay using the C# SDK so they arrive later. - [Expiration Policy](/docs/sdks/csharp/how-to/queues/expiration-policy): Set message expiration (TTL) on KubeMQ stream queues using the C# SDK to auto-remove stale messages. - [Nack All](/docs/sdks/csharp/how-to/queues/nack-all): Negative-acknowledge all received KubeMQ queue messages at once using the C# SDK to trigger redelivery. - [Peek Messages](/docs/sdks/csharp/how-to/queues/peek-messages): Peek at KubeMQ queue messages without consuming them using the C# SDK for non-destructive inspection. - [Poll Mode](/docs/sdks/csharp/how-to/queues/poll-mode): Pull KubeMQ queue messages on demand with polling mode using the C# SDK for controlled consumption. - [Requeue All](/docs/sdks/csharp/how-to/queues/requeue-all): Return all received KubeMQ queue messages to the queue for redelivery using the C# SDK. - [Stream Receive](/docs/sdks/csharp/how-to/queues/stream-receive): Receive KubeMQ queue messages via a streaming subscription using the C# SDK for continuous consumption. - [Stream Send](/docs/sdks/csharp/how-to/queues/stream-send): Stream messages to a KubeMQ queue channel for durable delivery using the C# SDK. - [Request-Reply](/docs/sdks/csharp/how-to/request-reply): Implement synchronous request-reply messaging over KubeMQ commands and queries using the C# SDK. - RPC - [RPC Examples](/docs/sdks/csharp/how-to/rpc): Commands and queries: request–reply, timeouts, groups, and caching. - [Command Group](/docs/sdks/csharp/how-to/rpc/command-group): Load-balance KubeMQ commands across a group of handlers using the C# SDK RPC client. - [Handle Command](/docs/sdks/csharp/how-to/rpc/command-handle): Register a handler for incoming KubeMQ commands using the C# SDK RPC client. - [Command Timeout](/docs/sdks/csharp/how-to/rpc/command-timeout): Handle KubeMQ command execution timeouts gracefully using the C# SDK RPC client. - [Cached Query](/docs/sdks/csharp/how-to/rpc/query-cached): Use server-side query response caching for KubeMQ queries with the C# SDK RPC client. - [Query Group](/docs/sdks/csharp/how-to/rpc/query-group): Load-balance KubeMQ queries across a group of handlers using the C# SDK RPC client. - [Handle Query](/docs/sdks/csharp/how-to/rpc/query-handle): Register a handler for incoming KubeMQ queries using the C# SDK RPC client. - TLS - [TLS & mTLS Examples](/docs/sdks/csharp/how-to/tls): Secure connections with TLS encryption and mutual TLS authentication (C# SDK). - [mTLS Setup](/docs/sdks/csharp/how-to/tls/mtls-setup): Configure mutual TLS authentication for C# client connections - [TLS Setup](/docs/sdks/csharp/how-to/tls/tls-setup): Configure server-side TLS encryption for C# client connections - [Work Queue](/docs/sdks/csharp/how-to/work-queue): Distribute work across competing consumers with a KubeMQ queue work-queue pattern using the C# SDK. - Reference - [Reference](/docs/sdks/csharp/reference): Complete API reference for the KubeMQ C# SDK client classes, messaging methods, and configuration. - [Client](/docs/sdks/csharp/reference/client): Construction, connect, and disposal — KubeMQ C# SDK reference. - [Events](/docs/sdks/csharp/reference/events): API reference for KubeMQ events (async pub/sub) in the C# SDK, covering SendEventAsync and SubscribeToEventsAsync. - [Events Store](/docs/sdks/csharp/reference/events-store): Durable events with replay — KubeMQ C# SDK reference. - [Queues](/docs/sdks/csharp/reference/queues): Durable queues and streaming — KubeMQ C# SDK reference. - [RPC](/docs/sdks/csharp/reference/rpc): API reference for KubeMQ commands and queries (RPC) in the C# SDK, covering SendCommandAsync and worker streaming helpers. - [Types & Errors](/docs/sdks/csharp/reference/types-and-errors): Retry policy, exceptions, and resources — KubeMQ C# SDK reference. - Kotlin - [Kotlin SDK](/docs/sdks/kotlin): Install the KubeMQ Kotlin SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/kotlin/tutorials): Learning-oriented, first-time lessons for the KubeMQ Kotlin SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/kotlin/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ events with Flow-based subscriptions using the Kotlin SDK. - [Send Command](/docs/sdks/kotlin/tutorials/command-send): Send a KubeMQ command to a handler and receive the execution result using the Kotlin SDK RPC client. - [Connect](/docs/sdks/kotlin/tutorials/connect): Basic client connection to KubeMQ server with DSL builders - [Send Your First Message](/docs/sdks/kotlin/tutorials/first-message): Connect the Kotlin client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/kotlin/tutorials/persistent-pubsub): Basic persistent event publishing and subscribing with Events Store - [Send Query](/docs/sdks/kotlin/tutorials/query-send): Send a KubeMQ query to a handler and receive response data with metadata and tags using the Kotlin SDK. - [Send & Receive](/docs/sdks/kotlin/tutorials/send-receive): Basic queue message send and receive with ack/reject - How-to guides - [How-to Guides](/docs/sdks/kotlin/how-to): Task-oriented recipes for the KubeMQ Kotlin SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/kotlin/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. (Kotlin SDK). - [Close a KubeMQ Kotlin Client](/docs/sdks/kotlin/how-to/connection/close): Close a KubeMQ Kotlin client cleanly to release the gRPC connection and free server-side resources. - [Custom Timeouts](/docs/sdks/kotlin/how-to/connection/custom-timeouts): Configure connection timeouts, keep-alive, reconnection backoff, and RPC timeouts on a KubeMQ Kotlin client. - [Ping](/docs/sdks/kotlin/how-to/connection/ping): Use ping() to verify KubeMQ server connectivity and read host, version, and uptime with the Kotlin SDK. - [Token Authentication](/docs/sdks/kotlin/how-to/connection/token-auth): Connect to KubeMQ with JWT token authentication using the Kotlin SDK via env vars or direct configuration. - Error Handling - [Error Handling Examples](/docs/sdks/kotlin/how-to/error-handling): Resilience, shutdown, and reconnection examples for the KubeMQ Kotlin SDK. - [Connection Error](/docs/sdks/kotlin/how-to/error-handling/connection-error): Handle KubeMQ connection errors with the sealed exception hierarchy and retryable error checks in the Kotlin SDK. - [Graceful Shutdown](/docs/sdks/kotlin/how-to/error-handling/graceful-shutdown): Properly shut down multiple clients and subscriptions - [Reconnection](/docs/sdks/kotlin/how-to/error-handling/reconnection): Automatic reconnection with backoff and connection state monitoring - Events - [Events Examples](/docs/sdks/kotlin/how-to/events): Real-time fire-and-forget pub/sub messaging examples for the KubeMQ Kotlin SDK. - [Cancel Subscription](/docs/sdks/kotlin/how-to/events/cancel-subscription): Cancel an active event subscription using coroutine cancellation - [Consumer Group](/docs/sdks/kotlin/how-to/events/consumer-group): Load-balanced event consumption across group members - [Multiple Subscribers](/docs/sdks/kotlin/how-to/events/multiple-subscribers): Broadcast events to multiple independent subscribers - [Stream Send](/docs/sdks/kotlin/how-to/events/stream-send): Publish KubeMQ events at high throughput with a Flow via publishEventStream() in the Kotlin SDK. - [Wildcard Subscription](/docs/sdks/kotlin/how-to/events/wildcard-subscription): Subscribe to multiple channels with wildcard patterns - Events Store - [Events Store Examples](/docs/sdks/kotlin/how-to/events-store): Persistent pub/sub with replay and time-based subscriptions for the KubeMQ Kotlin SDK. - [Cancel Subscription](/docs/sdks/kotlin/how-to/events-store/cancel-subscription): Cancel a KubeMQ events store subscription by cancelling its coroutine job using the Kotlin SDK. - [Consumer Group](/docs/sdks/kotlin/how-to/events-store/consumer-group): Load-balanced persistent event consumption across group members - [Replay from Sequence](/docs/sdks/kotlin/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/kotlin/how-to/events-store/replay-from-time): Replay KubeMQ events store messages from a specific timestamp with StartAtTime using the Kotlin SDK. - [Start at Time Delta](/docs/sdks/kotlin/how-to/events-store/start-at-time-delta): Subscribe to a KubeMQ events store channel from a relative time offset with StartAtTimeDelta in the Kotlin SDK. - [Start from First](/docs/sdks/kotlin/how-to/events-store/start-from-first): Replay the complete event history from the first event - [Start from Last](/docs/sdks/kotlin/how-to/events-store/start-from-last): Subscribe to a KubeMQ events store channel from the most recent event plus new ones with StartFromLast in Kotlin. - [Start New Only](/docs/sdks/kotlin/how-to/events-store/start-new-only): Receive only new events published after subscription - [Stream Send](/docs/sdks/kotlin/how-to/events-store/stream-send): High-throughput persistent event streaming with Flow - [Fan-Out](/docs/sdks/kotlin/how-to/fan-out): Broadcast messages to multiple independent subscribers - Management - [Management Examples](/docs/sdks/kotlin/how-to/management): Channel lifecycle and queue administration examples for the KubeMQ Kotlin SDK. - [Create Channel](/docs/sdks/kotlin/how-to/management/create-channel): Create KubeMQ channels for all five messaging types using the Kotlin SDK management API. - [Delete Channel](/docs/sdks/kotlin/how-to/management/delete-channel): Create and then delete KubeMQ channels using typed deletion methods in the Kotlin SDK management API. - [List Channels](/docs/sdks/kotlin/how-to/management/list-channels): List KubeMQ channels by type with optional prefix filtering using the Kotlin SDK management API. - [Purge Queue](/docs/sdks/kotlin/how-to/management/purge-queue): Purge all pending messages from a KubeMQ queue channel with purgeQueuesChannel in the Kotlin SDK. - Observability - [Observability Examples](/docs/sdks/kotlin/how-to/observability): OpenTelemetry tracing and metrics examples for the KubeMQ Kotlin SDK. - [OpenTelemetry Setup](/docs/sdks/kotlin/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing and metrics with the KubeMQ Kotlin SDK - Queues - [Queues Examples](/docs/sdks/kotlin/how-to/queues): Guaranteed delivery with simple and streaming queue APIs for the KubeMQ Kotlin SDK. - [Ack All](/docs/sdks/kotlin/how-to/queues/ack-all): Acknowledge all received KubeMQ queue messages in one batch with ackAllQueuesMessages in Kotlin. - [Ack Range](/docs/sdks/kotlin/how-to/queues/ack-range): Selectively acknowledge specific messages from a polled batch by sequence with the Kotlin SDK. - [Ack & Reject](/docs/sdks/kotlin/how-to/queues/ack-reject): Selectively acknowledge or reject messages based on content - [Auto Ack](/docs/sdks/kotlin/how-to/queues/auto-ack): Use automatic acknowledgement mode to ack KubeMQ queue messages on delivery with the Kotlin SDK. - [Batch Send](/docs/sdks/kotlin/how-to/queues/batch-send): Send multiple messages in a single batch operation - [Dead Letter Policy](/docs/sdks/kotlin/how-to/queues/dead-letter-policy): Field-level reference for QueueMessagePolicy's maxReceiveCount and maxReceiveQueue - [Dead Letter Queue](/docs/sdks/kotlin/how-to/queues/dead-letter-queue): Route failed messages to a dead letter queue after max retries - [Delay Policy](/docs/sdks/kotlin/how-to/queues/delay-policy): Send KubeMQ queue messages with staggered delays via QueueMessagePolicy using the Kotlin SDK. - [Delayed Messages](/docs/sdks/kotlin/how-to/queues/delayed-messages): Send a KubeMQ queue message with a delivery delay via QueueMessagePolicy using the Kotlin SDK. - [Expiration Policy](/docs/sdks/kotlin/how-to/queues/expiration-policy): Send KubeMQ queue messages with a TTL expiration policy that auto-removes expired messages, in Kotlin. - [Nack All](/docs/sdks/kotlin/how-to/queues/nack-all): Reject all received KubeMQ queue messages for redelivery with nackAllQueuesMessages in Kotlin. - [Peek Messages](/docs/sdks/kotlin/how-to/queues/peek-messages): Peek at KubeMQ queue messages without removing them so they stay in the queue, using the Kotlin SDK. - [Poll Mode](/docs/sdks/kotlin/how-to/queues/poll-mode): Pull-based message consumption with configurable batch size - [Requeue All](/docs/sdks/kotlin/how-to/queues/requeue-all): Move all received KubeMQ queue messages to a different queue with reQueueAllMessages in Kotlin. - [Stream Receive](/docs/sdks/kotlin/how-to/queues/stream-receive): Receive messages via streaming transport with manual ack - [Stream Send](/docs/sdks/kotlin/how-to/queues/stream-send): Send messages via streaming transport for high throughput - [Request-Reply](/docs/sdks/kotlin/how-to/request-reply): Implement the request-reply pattern over KubeMQ queries, awaiting a synchronous response, using the Kotlin SDK. - RPC - [RPC Examples](/docs/sdks/kotlin/how-to/rpc): Commands and queries (request-reply) examples for the KubeMQ Kotlin SDK. - [Command Group](/docs/sdks/kotlin/how-to/rpc/command-group): Load-balanced command handling across multiple workers - [Handle Command](/docs/sdks/kotlin/how-to/rpc/command-handle): Subscribe to and handle incoming commands with rich responses - [Command Timeout](/docs/sdks/kotlin/how-to/rpc/command-timeout): Configure KubeMQ command execution timeouts and handle expiry using the Kotlin SDK RPC client. - [Cached Query](/docs/sdks/kotlin/how-to/rpc/query-cached): Use server-side query response caching with cacheKey and cacheTtlSeconds for KubeMQ queries in Kotlin. - [Query Group](/docs/sdks/kotlin/how-to/rpc/query-group): Load-balanced query handling across multiple workers - [Handle Query](/docs/sdks/kotlin/how-to/rpc/query-handle): Subscribe to and handle incoming queries with rich responses - TLS - [TLS & mTLS Examples](/docs/sdks/kotlin/how-to/tls): TLS and mutual TLS setup examples for the KubeMQ Kotlin SDK. - [mTLS Setup](/docs/sdks/kotlin/how-to/tls/mtls-setup): Configure mutual TLS (mTLS) for a KubeMQ Kotlin client with file-based or PEM-bytes certificates. - [TLS Setup](/docs/sdks/kotlin/how-to/tls/tls-setup): Configure server-side TLS for encrypted KubeMQ connections, including config validation, in the Kotlin SDK. - [Work Queue](/docs/sdks/kotlin/how-to/work-queue): Distribute tasks across competing workers using queues - Reference - [Reference](/docs/sdks/kotlin/reference): Complete API reference for the KubeMQ Kotlin SDK client classes, messaging methods, and configuration. - [Client](/docs/sdks/kotlin/reference/client): Client classes, DSL builders, and lifecycle -- KubeMQ Kotlin SDK reference. - [Events](/docs/sdks/kotlin/reference/events): API reference for KubeMQ real-time pub/sub events in the Kotlin SDK PubSubClient, with the eventMessage DSL. - [Events Store](/docs/sdks/kotlin/reference/events-store): Durable events with replay -- KubeMQ Kotlin SDK reference. - [Queues](/docs/sdks/kotlin/reference/queues): Durable queues and streaming transports -- KubeMQ Kotlin SDK reference. - [RPC](/docs/sdks/kotlin/reference/rpc): Commands and queries -- KubeMQ Kotlin SDK reference. - [Types & Errors](/docs/sdks/kotlin/reference/types-and-errors): Sealed exception hierarchy, types, and performance guidance -- KubeMQ Kotlin SDK reference. - C++ - [C++ SDK](/docs/sdks/cpp): Install the KubeMQ C++ SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/cpp/tutorials): Learning-oriented, first-time lessons for the KubeMQ C++ SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/cpp/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ Events with the C++ SDK in a basic fire-and-forget pub/sub workflow. - [Send Command](/docs/sdks/cpp/tutorials/command-send): Send a KubeMQ Command with the C++ SDK and receive the handler's execution confirmation response. - [Connect](/docs/sdks/cpp/tutorials/connect): Establish a basic client connection to the KubeMQ server using the C++ SDK before sending or receiving messages. - [Send Your First Message](/docs/sdks/cpp/tutorials/first-message): Connect the C++ client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/cpp/tutorials/persistent-pubsub): Basic persistent event store publish and subscribe - [Send Query](/docs/sdks/cpp/tutorials/query-send): Send a KubeMQ Query and receive response data with the C++ SDK in a synchronous request-reply exchange. - [Send & Receive](/docs/sdks/cpp/tutorials/send-receive): Send and receive messages on a KubeMQ Queue channel with the C++ SDK in a basic producer-consumer workflow. - How-to guides - [How-to Guides](/docs/sdks/cpp/how-to): Task-oriented recipes for the KubeMQ C++ SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/cpp/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. (C++ SDK). - [Close a KubeMQ C++ Client](/docs/sdks/cpp/how-to/connection/close): Properly close a KubeMQ C++ SDK client connection to release server resources and avoid leaks on shutdown. - [Custom Timeouts](/docs/sdks/cpp/how-to/connection/custom-timeouts): Configure custom connection and operation timeouts for the KubeMQ C++ SDK client to tune reliability and latency. - [Ping](/docs/sdks/cpp/how-to/connection/ping): Ping the KubeMQ server with the C++ SDK to verify connectivity and read server health and version details. - [Token Authentication](/docs/sdks/cpp/how-to/connection/token-auth): Connect to the KubeMQ server with JWT token authentication using the C++ SDK for secure, authorized access. - Error Handling - [Error Handling Examples](/docs/sdks/cpp/how-to/error-handling): Resilience, shutdown, and reconnection examples for the C++ SDK. - [Connection Error](/docs/sdks/cpp/how-to/error-handling/connection-error): Detect and handle KubeMQ connection failures gracefully in the C++ SDK with proper error reporting and recovery. - [Graceful Shutdown](/docs/sdks/cpp/how-to/error-handling/graceful-shutdown): Handle OS signals and shut down a KubeMQ C++ SDK client cleanly with RAII, releasing connections and resources. - [Reconnection](/docs/sdks/cpp/how-to/error-handling/reconnection): Automatic reconnection with exponential backoff and state callbacks - Events - [Events Examples](/docs/sdks/cpp/how-to/events): Real-time fire-and-forget event pub/sub examples for the C++ SDK. - [Cancel Subscription](/docs/sdks/cpp/how-to/events/cancel-subscription): Cancel an active event subscription to stop receiving events - [Consumer Group](/docs/sdks/cpp/how-to/events/consumer-group): Load-balanced event delivery using consumer groups - [Multiple Subscribers](/docs/sdks/cpp/how-to/events/multiple-subscribers): Fan-out delivery to multiple subscribers without consumer groups - [Stream Send](/docs/sdks/cpp/how-to/events/stream-send): High-throughput event publishing using SendEventStream - [Wildcard Subscription](/docs/sdks/cpp/how-to/events/wildcard-subscription): Subscribe to events using wildcard channel patterns - Events Store - [Events Store Examples](/docs/sdks/cpp/how-to/events-store): Persistent event pub/sub with replay examples for the C++ SDK. - [Cancel Subscription](/docs/sdks/cpp/how-to/events-store/cancel-subscription): Cancel an active subscription to a KubeMQ Events Store channel and stop receiving persisted events in the C++ SDK. - [Consumer Group](/docs/sdks/cpp/how-to/events-store/consumer-group): Load-balanced persistent event delivery with consumer groups - [Replay from Sequence](/docs/sdks/cpp/how-to/events-store/replay-from-sequence): Replay events starting from a specific sequence number - [Replay from Time](/docs/sdks/cpp/how-to/events-store/replay-from-time): Replay events starting from a specific point in time - [Start at Time Delta](/docs/sdks/cpp/how-to/events-store/start-at-time-delta): Subscribe to a KubeMQ Events Store channel and replay events from a relative time offset using the C++ SDK. - [Start from First](/docs/sdks/cpp/how-to/events-store/start-from-first): Subscribe to a KubeMQ Events Store channel and replay all events from the beginning of the store using the C++ SDK. - [Start from Last](/docs/sdks/cpp/how-to/events-store/start-from-last): Subscribe to a KubeMQ Events Store channel starting from the most recently stored event using the C++ SDK. - [Start New Only](/docs/sdks/cpp/how-to/events-store/start-new-only): Receive only new events after subscription is established - [Stream Send](/docs/sdks/cpp/how-to/events-store/stream-send): High-throughput persistent event publishing via streams - [Fan-Out](/docs/sdks/cpp/how-to/fan-out): Broadcast events to multiple independent subscribers - Management - [Management Examples](/docs/sdks/cpp/how-to/management): Channel lifecycle and queue administration examples for the C++ SDK. - [Create Channel](/docs/sdks/cpp/how-to/management/create-channel): Programmatically create KubeMQ channels of different types using the C++ SDK administration API. - [Delete Channel](/docs/sdks/cpp/how-to/management/delete-channel): Delete an existing KubeMQ channel by name and type using the C++ SDK administration API for cleanup and management. - [List Channels](/docs/sdks/cpp/how-to/management/list-channels): List active KubeMQ channels with an optional search filter using the C++ SDK administration API to inspect them. - [Purge Queue](/docs/sdks/cpp/how-to/management/purge-queue): Purge all pending messages from a KubeMQ Queue channel using the C++ SDK administration API to reset its state. - Observability - [Observability Examples](/docs/sdks/cpp/how-to/observability): OpenTelemetry tracing and metrics examples for the C++ SDK. - [OpenTelemetry Setup](/docs/sdks/cpp/how-to/observability/opentelemetry-setup): Configure distributed tracing and metrics with OpenTelemetry - Queues - [Queues Examples](/docs/sdks/cpp/how-to/queues): Guaranteed delivery queue examples with simple and streaming APIs for the C++ SDK. - [Ack All](/docs/sdks/cpp/how-to/queues/ack-all): Acknowledge all pending KubeMQ Queue messages at once with the C++ SDK to confirm a full batch in a single call. - [Ack Range](/docs/sdks/cpp/how-to/queues/ack-range): Selectively acknowledge specific messages in a transaction - [Ack & Reject](/docs/sdks/cpp/how-to/queues/ack-reject): Selectively acknowledge or reject individual KubeMQ Queue messages with the C++ SDK to control redelivery. - [Auto Ack](/docs/sdks/cpp/how-to/queues/auto-ack): Automatic acknowledgment of queue messages on receipt - [Batch Send](/docs/sdks/cpp/how-to/queues/batch-send): Send multiple KubeMQ Queue messages in a single batch with the C++ SDK to reduce round-trips and boost throughput. - [Dead Letter Policy](/docs/sdks/cpp/how-to/queues/dead-letter-policy): Configure dead-letter queue policy via upstream streams - [Dead Letter Queue](/docs/sdks/cpp/how-to/queues/dead-letter-queue): Route repeatedly failed KubeMQ Queue messages to a dead-letter queue with the C++ SDK for later inspection. - [Delay Policy](/docs/sdks/cpp/how-to/queues/delay-policy): Configure a message delay policy on a KubeMQ Queue via the upstream stream API in the C++ SDK to defer delivery. - [Delayed Messages](/docs/sdks/cpp/how-to/queues/delayed-messages): Send KubeMQ Queue messages with delayed delivery using the C++ SDK so consumers receive them after a set interval. - [Expiration Policy](/docs/sdks/cpp/how-to/queues/expiration-policy): Configure message expiration TTL on a KubeMQ Queue via the upstream stream API in the C++ SDK to drop stale messages. - [Nack All](/docs/sdks/cpp/how-to/queues/nack-all): Negative-acknowledge all messages in a poll response - [Peek Messages](/docs/sdks/cpp/how-to/queues/peek-messages): Peek at messages in a KubeMQ Queue channel without consuming them using the C++ SDK to inspect pending work. - [Poll Mode](/docs/sdks/cpp/how-to/queues/poll-mode): Poll a KubeMQ Queue for messages with a configurable timeout using the C++ SDK for explicit, batch-controlled consumption. - [Requeue All](/docs/sdks/cpp/how-to/queues/requeue-all): Re-queue all received KubeMQ Queue messages to another channel with the C++ SDK to redirect undelivered work. - [Stream Receive](/docs/sdks/cpp/how-to/queues/stream-receive): Receive KubeMQ Queue messages with the C++ SDK using the downstream queue stream API for continuous consumption. - [Stream Send](/docs/sdks/cpp/how-to/queues/stream-send): Send messages to a KubeMQ Queue channel via the upstream queue stream API in the C++ SDK for high throughput. - [Request-Reply](/docs/sdks/cpp/how-to/request-reply): Implement synchronous request-reply communication over KubeMQ Queries using the C++ SDK. - RPC - [RPC Examples](/docs/sdks/cpp/how-to/rpc): Command and query request-reply examples for the C++ SDK. - [Command Group](/docs/sdks/cpp/how-to/rpc/command-group): Load-balanced command handling with consumer groups - [Handle Command](/docs/sdks/cpp/how-to/rpc/command-handle): Subscribe to and handle incoming commands with business logic - [Command Timeout](/docs/sdks/cpp/how-to/rpc/command-timeout): Handle KubeMQ Command timeouts with the C++ SDK when no handler responds within the configured window. - [Cached Query](/docs/sdks/cpp/how-to/rpc/query-cached): Cache KubeMQ Query responses with the C++ SDK using CacheKey and CacheTTL to serve repeated requests faster. - [Query Group](/docs/sdks/cpp/how-to/rpc/query-group): Load-balance KubeMQ Query handling across a consumer group with the C++ SDK so each query is answered once. - [Handle Query](/docs/sdks/cpp/how-to/rpc/query-handle): Subscribe to and handle incoming queries with data responses - TLS - [TLS & mTLS Examples](/docs/sdks/cpp/how-to/tls): TLS and mutual TLS connection security examples for the C++ SDK. - [mTLS Setup](/docs/sdks/cpp/how-to/tls/mtls-setup): Configure mutual TLS with client certificates for the KubeMQ C++ SDK to secure connections to the server. - [TLS Setup](/docs/sdks/cpp/how-to/tls/tls-setup): Configure TLS with CA certificate for secure connections - [Work Queue](/docs/sdks/cpp/how-to/work-queue): Competing consumers with queue-based task distribution - Reference - [Reference](/docs/sdks/cpp/reference): Complete API reference for the KubeMQ C++ SDK, covering Events, Events Store, Queues, Commands, Queries, and management. - [Client](/docs/sdks/cpp/reference/client): Client construction, configuration, and lifecycle -- KubeMQ C++ SDK reference. - [Events](/docs/sdks/cpp/reference/events): Event publishing and subscription methods -- KubeMQ C++ SDK reference. - [Events Store](/docs/sdks/cpp/reference/events-store): Persistent event publishing and subscription with replay -- KubeMQ C++ SDK reference. - [Queues](/docs/sdks/cpp/reference/queues): Queue messaging methods (Simple and Stream APIs) -- KubeMQ C++ SDK reference. - [RPC](/docs/sdks/cpp/reference/rpc): Commands and queries (request-reply) methods -- KubeMQ C++ SDK reference. - [Types & Errors](/docs/sdks/cpp/reference/types-and-errors): Shared types, Status/StatusOr, error codes, and constants -- KubeMQ C++ SDK reference. - Rust - [Rust SDK](/docs/sdks/rust): Install the KubeMQ Rust SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/rust/tutorials): Learning-oriented, first-time lessons for the KubeMQ Rust SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/rust/tutorials/basic-pubsub): Publish and subscribe to fire-and-forget KubeMQ Events with the Rust SDK for real-time pub/sub messaging. - [Send Command](/docs/sdks/rust/tutorials/command-send): Send a KubeMQ Command and wait for the handler's execution result using the Rust SDK. - [Connect](/docs/sdks/rust/tutorials/connect): Create a KubeMQ client connection with builder options and verify it with a ping using the Rust SDK. - [Send Your First Message](/docs/sdks/rust/tutorials/first-message): Connect the Rust client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/rust/tutorials/persistent-pubsub): Publish and subscribe to persistent events with replay - [Send Query](/docs/sdks/rust/tutorials/query-send): Send a KubeMQ Query and receive a response with data in request-reply style using the Rust SDK. - [Send & Receive](/docs/sdks/rust/tutorials/send-receive): Send a message to a KubeMQ queue channel and pull it back with the Rust SDK for basic queue messaging. - How-to guides - [How-to Guides](/docs/sdks/rust/how-to): Task-oriented recipes for the KubeMQ Rust SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/rust/how-to/connection): Connection, configuration, and lifecycle examples for the KubeMQ Rust SDK, from basic connect to graceful shutdown. - [Close a KubeMQ Rust Client](/docs/sdks/rust/how-to/connection/close): Close a KubeMQ Rust client gracefully after connecting and verifying with a ping to release resources. - [Custom Timeouts](/docs/sdks/rust/how-to/connection/custom-timeouts): Configure retry policy, keepalive, and connection callbacks - [Ping](/docs/sdks/rust/how-to/connection/ping): Send a ping to verify KubeMQ connectivity and read server information using the Rust SDK. - [Token Auth](/docs/sdks/rust/how-to/connection/token-auth): Connect to a KubeMQ broker with an authentication token sent as gRPC metadata using the Rust SDK. - Error Handling - [Error Handling Examples](/docs/sdks/rust/how-to/error-handling): Error handling, graceful shutdown, and reconnection examples - [Connection Error](/docs/sdks/rust/how-to/error-handling/connection-error): Handle connection failures and error classification. - [Graceful Shutdown](/docs/sdks/rust/how-to/error-handling/graceful-shutdown): Shut down KubeMQ subscriptions and the client cleanly in Rust, unsubscribing before exit for production-safe operation. - [Reconnection](/docs/sdks/rust/how-to/error-handling/reconnection): Retry policy with exponential backoff and state callbacks. - Events - [Events Examples](/docs/sdks/rust/how-to/events): Real-time fire-and-forget pub/sub examples for KubeMQ Events in Rust: channels, subscribers, and streaming sends. - [Cancel Subscription](/docs/sdks/rust/how-to/events/cancel-subscription): Cancel an active KubeMQ Events subscription at runtime so later events are not delivered, using the Rust SDK. - [Consumer Group](/docs/sdks/rust/how-to/events/consumer-group): Load-balanced event delivery across a consumer group - [Multiple Subscribers](/docs/sdks/rust/how-to/events/multiple-subscribers): Fan out KubeMQ Events to multiple subscribers on the same channel so each receives every event, in Rust. - [Stream Send](/docs/sdks/rust/how-to/events/stream-send): High-throughput event publishing via a persistent gRPC stream - [Wildcard Subscription](/docs/sdks/rust/how-to/events/wildcard-subscription): Subscribe to multiple channels using wildcard patterns - Events Store - [Events Store Examples](/docs/sdks/rust/how-to/events-store): Persistent pub/sub examples for KubeMQ Events Store in Rust: replay, consumer groups, and time-based subscriptions. - [Cancel Subscription](/docs/sdks/rust/how-to/events-store/cancel-subscription): Cancel an active KubeMQ Events Store subscription cleanly after receiving events using the Rust SDK. - [Consumer Group](/docs/sdks/rust/how-to/events-store/consumer-group): Load-balanced persistent event delivery using consumer groups - [Replay from Sequence](/docs/sdks/rust/how-to/events-store/replay-from-sequence): Start reading events from a specific sequence number - [Replay from Time](/docs/sdks/rust/how-to/events-store/replay-from-time): Replay KubeMQ Events Store messages from a specific wall-clock timestamp using the Rust SDK. - [Start at Time Delta](/docs/sdks/rust/how-to/events-store/start-at-time-delta): Subscribe to KubeMQ Events Store from a relative time offset such as 30 seconds ago using the Rust SDK. - [Start from First](/docs/sdks/rust/how-to/events-store/start-from-first): Replay every stored KubeMQ Events Store message from the beginning using StartFromFirst in Rust. - [Start from Last](/docs/sdks/rust/how-to/events-store/start-from-last): Subscribe to KubeMQ Events Store from the most recent stored event and continue forward using the Rust SDK. - [Start New Only](/docs/sdks/rust/how-to/events-store/start-new-only): Subscribe to only newly published KubeMQ Events Store messages, ignoring history, using StartNewOnly in Rust. - [Stream Send](/docs/sdks/rust/how-to/events-store/stream-send): High-throughput persistent event publishing via gRPC stream - [Fan-Out](/docs/sdks/rust/how-to/fan-out): Broadcast KubeMQ Events from one publisher to multiple subscribers in Rust so each subscriber receives every event. - Management - [Management Examples](/docs/sdks/rust/how-to/management): Channel management examples for the KubeMQ Rust SDK: create, list, and delete channels and purge queues. - [Create Channel](/docs/sdks/rust/how-to/management/create-channel): Create KubeMQ channels for every messaging pattern type, Events, Events Store, Commands, Queries, and Queues, in Rust. - [Delete Channel](/docs/sdks/rust/how-to/management/delete-channel): Delete KubeMQ channels by name and type from the broker using the Rust SDK management API. - [List Channels](/docs/sdks/rust/how-to/management/list-channels): List KubeMQ channels by type with an optional search filter and read their statistics using the Rust SDK. - [Purge Queue](/docs/sdks/rust/how-to/management/purge-queue): Purge all messages from a KubeMQ queue channel to clear it using the Rust SDK management API. - Observability - [Observability Examples](/docs/sdks/rust/how-to/observability): Observability examples for the KubeMQ Rust SDK: configure OpenTelemetry tracing and metrics for your messaging. - [OpenTelemetry Setup](/docs/sdks/rust/how-to/observability/opentelemetry-setup): Bridge the KubeMQ Rust SDK tracing events to OpenTelemetry to export traces and metrics to backends like Jaeger or OTLP. - Queues - [Queues Examples](/docs/sdks/rust/how-to/queues): Point-to-point queue messaging examples for the KubeMQ Rust SDK using the simple and streaming Queues APIs. - [Ack All](/docs/sdks/rust/how-to/queues/ack-all): Acknowledge all pending KubeMQ queue messages at once with ack_all_queue_messages using the Rust SDK. - [Ack Range](/docs/sdks/rust/how-to/queues/ack-range): Acknowledge a range of KubeMQ queue messages by sequence using the stream downstream API in Rust. - [Ack & Reject](/docs/sdks/rust/how-to/queues/ack-reject): Acknowledge or reject individual KubeMQ queue messages using the stream downstream API in Rust. - [Auto Ack](/docs/sdks/rust/how-to/queues/auto-ack): Automatically acknowledge KubeMQ queue messages on delivery using the simple receive API in Rust. - [Batch Send](/docs/sdks/rust/how-to/queues/batch-send): Send multiple queue messages in a single batch operation - [Dead Letter Policy](/docs/sdks/rust/how-to/queues/dead-letter-policy): Configure dead-letter routing on KubeMQ Queues via QueuePolicy in Rust to handle repeatedly failed messages. - [Dead Letter Queue](/docs/sdks/rust/how-to/queues/dead-letter-queue): Route failed KubeMQ queue messages to a dead-letter channel via QueuePolicy using the Rust SDK. - [Delay Policy](/docs/sdks/rust/how-to/queues/delay-policy): Configure delayed message delivery via stream policy - [Delayed Messages](/docs/sdks/rust/how-to/queues/delayed-messages): Delay KubeMQ queue message delivery by a set duration in Rust so consumers see it only after the delay. - [Expiration Policy](/docs/sdks/rust/how-to/queues/expiration-policy): Configure message expiration on KubeMQ Queues via QueuePolicy in Rust to discard stale messages automatically. - [Nack All](/docs/sdks/rust/how-to/queues/nack-all): Negative-acknowledge all queue messages for redelivery. - [Peek Messages](/docs/sdks/rust/how-to/queues/peek-messages): Peek at KubeMQ queue messages without consuming them using the Rust SDK so they remain for future processing. - [Poll Mode](/docs/sdks/rust/how-to/queues/poll-mode): Poll for KubeMQ queue messages with a configurable wait timeout that blocks until messages arrive, in Rust. - [Requeue All](/docs/sdks/rust/how-to/queues/requeue-all): Requeue all messages to a different channel for redelivery. - [Stream Receive](/docs/sdks/rust/how-to/queues/stream-receive): Consume KubeMQ queue messages via the downstream stream API with manual acknowledgement control in Rust. - [Stream Send](/docs/sdks/rust/how-to/queues/stream-send): High-throughput queue publishing via upstream stream. - [Request-Reply](/docs/sdks/rust/how-to/request-reply): Synchronous request-response using Commands and Queries. - RPC - [RPC Examples](/docs/sdks/rust/how-to/rpc): Command and query request-reply examples for the KubeMQ Rust SDK: timeouts, consumer groups, and caching. - [Command Group](/docs/sdks/rust/how-to/rpc/command-group): Load-balanced command handling via consumer groups - [Handle Command](/docs/sdks/rust/how-to/rpc/command-handle): Subscribe to and handle incoming KubeMQ Commands, performing the action and sending a reply, in Rust. - [Command Timeout](/docs/sdks/rust/how-to/rpc/command-timeout): Handle KubeMQ Command timeouts when no subscriber responds in time, returning a Timeout error, in Rust. - [Cached Query](/docs/sdks/rust/how-to/rpc/query-cached): Enable server-side response caching for KubeMQ Queries with a cache key and TTL using the Rust SDK. - [Query Group](/docs/sdks/rust/how-to/rpc/query-group): Load-balance KubeMQ Queries across handlers with consumer groups so each query reaches one handler, in Rust. - [Handle Query](/docs/sdks/rust/how-to/rpc/query-handle): Subscribe to and handle incoming KubeMQ Queries, returning response data, using the Rust SDK. - TLS - [TLS & mTLS Examples](/docs/sdks/rust/how-to/tls): TLS and mutual TLS examples for the KubeMQ Rust SDK to encrypt and authenticate broker connections. - [mTLS Setup](/docs/sdks/rust/how-to/tls/mtls-setup): Connect with mutual TLS client certificate authentication - [TLS Setup](/docs/sdks/rust/how-to/tls/tls-setup): Connect to a KubeMQ broker over a TLS-encrypted channel using a CA certificate with the Rust SDK. - [Work Queue](/docs/sdks/rust/how-to/work-queue): Distribute tasks across multiple workers using KubeMQ Queues in Rust so each message is delivered to exactly one worker. - Reference - [Rust SDK Reference](/docs/sdks/rust/reference): Complete API reference for the KubeMQ Rust SDK covering all types, traits, and methods. - [Client](/docs/sdks/rust/reference/client): KubemqClient, ClientConfigBuilder, and connection types - [Events](/docs/sdks/rust/reference/events): Event, EventReceive, and streaming types for fire-and-forget pub/sub - [Events Store](/docs/sdks/rust/reference/events-store): EventStore, replay types, and persistent pub/sub operations - [Queues](/docs/sdks/rust/reference/queues): QueueMessage, QueuePolicy, and point-to-point queue operations - [RPC](/docs/sdks/rust/reference/rpc): Command, Query, response types, and request-response operations - [Types & Errors](/docs/sdks/rust/reference/types-and-errors): KubemqError enum, ErrorCode, Result type alias, and common types - Ruby - [Ruby SDK](/docs/sdks/ruby): Install the KubeMQ Ruby SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/ruby/tutorials): Learning-oriented, first-time lessons for the KubeMQ Ruby SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/ruby/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ events with the Ruby SDK for fire-and-forget pub/sub messaging across clients. - [Send Command](/docs/sdks/ruby/tutorials/command-send): Send a KubeMQ command and receive confirmation in Ruby using request-reply for reliable remote command invocation. - [Connect](/docs/sdks/ruby/tutorials/connect): Establish a basic client connection to the KubeMQ server with the Ruby SDK, setting the address and client ID to start messaging. - [Send Your First Message](/docs/sdks/ruby/tutorials/first-message): Connect the Ruby client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/ruby/tutorials/persistent-pubsub): Publish and subscribe to a KubeMQ Events Store channel in Ruby for durable, replayable pub/sub with persisted event delivery. - [Send Query](/docs/sdks/ruby/tutorials/query-send): Send a KubeMQ query and receive a data response in Ruby using request-reply to fetch results from a remote handler. - [Send & Receive](/docs/sdks/ruby/tutorials/send-receive): Send and receive messages on a KubeMQ queue channel with the Ruby SDK for basic guaranteed-delivery queue messaging. - How-to guides - [How-to Guides](/docs/sdks/ruby/how-to): Task-oriented recipes for the KubeMQ Ruby SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection & Config Examples](/docs/sdks/ruby/how-to/connection): Connect to KubeMQ, authenticate, tune timeouts, and close clients safely. - [Close a KubeMQ Ruby Client](/docs/sdks/ruby/how-to/connection/close): Properly close a KubeMQ client connection in Ruby, releasing sockets and resources cleanly on application shutdown. - [Custom Timeouts](/docs/sdks/ruby/how-to/connection/custom-timeouts): Configure connection and per-operation timeouts on the KubeMQ Ruby client to tune reliability under slow networks and load. - [Ping](/docs/sdks/ruby/how-to/connection/ping): Health check ping to verify KubeMQ server connectivity. - [Token Authentication](/docs/sdks/ruby/how-to/connection/token-auth): Connect to the KubeMQ server using bearer token authentication with the Ruby SDK to secure client access with credentials. - Error Handling - [Error Handling Examples](/docs/sdks/ruby/how-to/error-handling): Resilience examples for the KubeMQ Ruby SDK: graceful shutdown, connection-error handling, and automatic reconnection patterns. - [Connection Error](/docs/sdks/ruby/how-to/error-handling/connection-error): Handle KubeMQ connection failures gracefully in the Ruby SDK, catching connect errors and reporting actionable diagnostics. - [Graceful Shutdown](/docs/sdks/ruby/how-to/error-handling/graceful-shutdown): Perform a clean KubeMQ shutdown in Ruby by cancelling subscriptions and releasing client resources before the process exits. - [Reconnection](/docs/sdks/ruby/how-to/error-handling/reconnection): Automatically reconnect to the KubeMQ server in Ruby using exponential backoff to recover from disconnections and resume messaging. - Events - [Events Examples](/docs/sdks/ruby/how-to/events): Real-time fire-and-forget pub/sub messaging examples. - [Cancel Subscription](/docs/sdks/ruby/how-to/events/cancel-subscription): Stop receiving KubeMQ events in Ruby using a cancellation token to cleanly unsubscribe from a pub/sub channel. - [Consumer Group](/docs/sdks/ruby/how-to/events/consumer-group): Load-balance KubeMQ event delivery across a consumer group in Ruby so each event is handled by exactly one subscriber. - [Multiple Subscribers](/docs/sdks/ruby/how-to/events/multiple-subscribers): Fan-out events to multiple independent subscribers. - [Stream Send](/docs/sdks/ruby/how-to/events/stream-send): High-throughput event publishing over a long-lived stream. - [Wildcard Subscription](/docs/sdks/ruby/how-to/events/wildcard-subscription): Subscribe to events across multiple channels with wildcards. - Events Store - [Events Store Examples](/docs/sdks/ruby/how-to/events-store): Persistent pub/sub with replay and time-based subscriptions. - [Cancel Subscription](/docs/sdks/ruby/how-to/events-store/cancel-subscription): Stop receiving KubeMQ Events Store messages in Ruby by cancelling the subscription and cleanly closing the persistent stream. - [Consumer Group](/docs/sdks/ruby/how-to/events-store/consumer-group): Load-balanced events store delivery across subscribers. - [Replay from Sequence](/docs/sdks/ruby/how-to/events-store/replay-from-sequence): Resume events store from a specific sequence number. - [Replay from Time](/docs/sdks/ruby/how-to/events-store/replay-from-time): Resume a KubeMQ Events Store subscription from a specific timestamp in Ruby to reprocess persisted events from a known point. - [Start at Time Delta](/docs/sdks/ruby/how-to/events-store/start-at-time-delta): Resume a KubeMQ Events Store subscription from a relative time offset in Ruby, replaying events from the last N seconds or minutes. - [Start from First](/docs/sdks/ruby/how-to/events-store/start-from-first): Replay all KubeMQ Events Store messages from the beginning in Ruby, reprocessing the full channel history from the first event. - [Start from Last](/docs/sdks/ruby/how-to/events-store/start-from-last): Subscribe to a KubeMQ Events Store channel from the most recent stored event in Ruby to start with the latest persisted state. - [Start New Only](/docs/sdks/ruby/how-to/events-store/start-new-only): Subscribe to a KubeMQ Events Store channel for new events only in Ruby, skipping stored history and receiving only future events. - [Stream Send](/docs/sdks/ruby/how-to/events-store/stream-send): High-throughput events store publishing via persistent stream. - [Fan-Out](/docs/sdks/ruby/how-to/fan-out): Broadcast events to multiple independent subscribers. - Management - [Management Examples](/docs/sdks/ruby/how-to/management): Channel lifecycle and queue administration examples for the KubeMQ Ruby SDK: create, list, delete channels, and purge queues. - [Create Channel](/docs/sdks/ruby/how-to/management/create-channel): Create messaging channels on the KubeMQ broker with the Ruby SDK, provisioning queues or pub/sub topics before traffic arrives. - [Delete Channel](/docs/sdks/ruby/how-to/management/delete-channel): Delete messaging channels from the KubeMQ broker with the Ruby SDK to clean up unused queues and pub/sub topics programmatically. - [List Channels](/docs/sdks/ruby/how-to/management/list-channels): List KubeMQ channels by type with optional name filtering using the Ruby SDK to inspect active queues and pub/sub topics. - [Purge Queue](/docs/sdks/ruby/how-to/management/purge-queue): Remove all messages from a KubeMQ queue channel with the Ruby SDK to clear a backlog and reset the queue to an empty state. - Observability - [Observability Examples](/docs/sdks/ruby/how-to/observability): OpenTelemetry tracing and metrics examples for the KubeMQ Ruby SDK to instrument messaging and export spans to a collector. - [OpenTelemetry Setup](/docs/sdks/ruby/how-to/observability/opentelemetry-setup): Configure OpenTelemetry tracing for KubeMQ messaging. - Queues - [Queues Examples](/docs/sdks/ruby/how-to/queues): Guaranteed delivery with simple and streaming queue APIs. - [Ack All](/docs/sdks/ruby/how-to/queues/ack-all): Acknowledge all pending KubeMQ queue messages at once in Ruby to confirm an entire batch with a single acknowledgement call. - [Ack Range](/docs/sdks/ruby/how-to/queues/ack-range): Acknowledge a contiguous range of KubeMQ queue messages by sequence in Ruby to confirm many deliveries in a single call. - [Ack/Reject](/docs/sdks/ruby/how-to/queues/ack-reject): Acknowledge or reject individual KubeMQ queue messages in Ruby to confirm successful processing and discard failed deliveries. - [Auto Ack](/docs/sdks/ruby/how-to/queues/auto-ack): Automatically acknowledge KubeMQ queue messages on receipt in Ruby so messages are removed on delivery without manual ack calls. - [Batch Send](/docs/sdks/ruby/how-to/queues/batch-send): Send multiple KubeMQ queue messages in a single batch with the Ruby SDK to improve throughput and reduce round trips. - [Dead Letter Policy](/docs/sdks/ruby/how-to/queues/dead-letter-policy): Configure automatic dead-letter routing via policy. - [Dead Letter Queue](/docs/sdks/ruby/how-to/queues/dead-letter-queue): Route failed KubeMQ queue messages to a dead-letter queue in Ruby, diverting poison messages after retries are exhausted. - [Delay Policy](/docs/sdks/ruby/how-to/queues/delay-policy): Field-level reference for QueueMessagePolicy#delay_seconds, the object that configures delivery delay in the Ruby SDK. - [Delayed Messages](/docs/sdks/ruby/how-to/queues/delayed-messages): Send KubeMQ queue messages with a delivery delay in Ruby so consumers receive them only after the specified time elapses. - [Expiration Policy](/docs/sdks/ruby/how-to/queues/expiration-policy): Configure message TTL via an expiration policy on KubeMQ queues in Ruby so stale messages are dropped before delivery. - [Nack All](/docs/sdks/ruby/how-to/queues/nack-all): Negative-acknowledge all KubeMQ queue messages in a batch in Ruby, rejecting them together so the server can redeliver them. - [Peek Messages](/docs/sdks/ruby/how-to/queues/peek-messages): Inspect KubeMQ queue messages without removing them in Ruby, peeking at payloads while leaving them available for consumers. - [Poll Mode](/docs/sdks/ruby/how-to/queues/poll-mode): Poll a KubeMQ queue for available messages without blocking in Ruby, fetching batches on demand when the consumer is ready. - [Requeue All](/docs/sdks/ruby/how-to/queues/requeue-all): Requeue all received KubeMQ queue messages to a different channel in Ruby, redirecting an entire batch for later processing. - [Stream Receive](/docs/sdks/ruby/how-to/queues/stream-receive): Receive KubeMQ queue messages over a persistent stream in Ruby with per-message acknowledge, reject, and requeue control. - [Stream Send](/docs/sdks/ruby/how-to/queues/stream-send): High-throughput queue sending via persistent stream. - [Request-Reply](/docs/sdks/ruby/how-to/request-reply): Implement the synchronous request-reply pattern over KubeMQ queries in Ruby, sending a request and waiting for the responder's reply. - RPC - [RPC Examples](/docs/sdks/ruby/how-to/rpc): Commands and queries request-reply examples for the KubeMQ Ruby SDK, covering send, handle, grouping, timeouts, and caching. - [Command Group](/docs/sdks/ruby/how-to/rpc/command-group): Load-balance KubeMQ command handling across a handler group in Ruby so each command is processed by one available worker. - [Handle Command](/docs/sdks/ruby/how-to/rpc/command-handle): Subscribe to and process incoming KubeMQ commands in Ruby, handling each request and returning an execution result. - [Command Timeout](/docs/sdks/ruby/how-to/rpc/command-timeout): Handle KubeMQ command timeouts in Ruby when no handler responds in time, failing the request cleanly with a clear error. - [Cached Query](/docs/sdks/ruby/how-to/rpc/query-cached): Send a cached KubeMQ query in Ruby, serving repeat requests from the server-side cache to skip the handler and cut latency. - [Query Group](/docs/sdks/ruby/how-to/rpc/query-group): Load-balance KubeMQ query handling across a handler group in Ruby so each query is answered by one available responder. - [Handle Query](/docs/sdks/ruby/how-to/rpc/query-handle): Subscribe to and process incoming KubeMQ queries in Ruby, handling each request and returning a data response to the caller. - TLS - [TLS & mTLS Examples](/docs/sdks/ruby/how-to/tls): TLS and mutual TLS configuration examples for the KubeMQ Ruby SDK to encrypt and authenticate client-to-server connections. - [mTLS Setup](/docs/sdks/ruby/how-to/tls/mtls-setup): Connect with mutual TLS client certificate authentication. - [TLS Setup](/docs/sdks/ruby/how-to/tls/tls-setup): Connect to the KubeMQ server with server TLS verification in Ruby, encrypting traffic and validating the server certificate. - [Work Queue](/docs/sdks/ruby/how-to/work-queue): Competing consumers processing from a shared queue. - Reference - [Reference](/docs/sdks/ruby/reference): Complete API reference for the KubeMQ Ruby SDK: client classes, events, events store, queues, RPC methods, types, and errors. - [Client](/docs/sdks/ruby/reference/client): KubeMQ Ruby SDK client classes, constructors, configuration, and lifecycle methods. - [Events](/docs/sdks/ruby/reference/events): KubeMQ Ruby SDK API reference for real-time fire-and-forget event pub/sub. - [Events Store](/docs/sdks/ruby/reference/events-store): KubeMQ Ruby SDK API reference for persistent pub/sub with replay capabilities. - [Queues](/docs/sdks/ruby/reference/queues): KubeMQ Ruby SDK API reference for guaranteed message delivery with queues. - [RPC](/docs/sdks/ruby/reference/rpc): KubeMQ Ruby SDK API reference for commands and queries (request-reply). - [Types & Errors](/docs/sdks/ruby/reference/types-and-errors): KubeMQ Ruby SDK shared types, error hierarchy, and configuration classes. - Elixir - [Elixir SDK](/docs/sdks/elixir): Install the KubeMQ Elixir SDK and send your first message with step-by-step instructions. - Tutorials - [Tutorials](/docs/sdks/elixir/tutorials): Learning-oriented, first-time lessons for the KubeMQ Elixir SDK — connect, then send your first message with each messaging pattern. - [Basic Pub/Sub](/docs/sdks/elixir/tutorials/basic-pubsub): Publish and subscribe to real-time KubeMQ events with the Elixir SDK in a basic pub/sub example. - [Send Command](/docs/sdks/elixir/tutorials/command-send): Send a command and wait for execution confirmation. - [Connect](/docs/sdks/elixir/tutorials/connect): Establish a basic client connection to the KubeMQ server using the Elixir SDK and verify it succeeds. - [Send Your First Message](/docs/sdks/elixir/tutorials/first-message): Connect the Elixir client to KubeMQ and publish and receive your first message end to end. - [Persistent Pub/Sub](/docs/sdks/elixir/tutorials/persistent-pubsub): Publish and subscribe to persistent KubeMQ Events Store messages using the Elixir SDK pub/sub API. - [Send Query](/docs/sdks/elixir/tutorials/query-send): Send a KubeMQ query and receive a data response from a handler using the Elixir SDK. - [Send & Receive](/docs/sdks/elixir/tutorials/send-receive): Send and receive messages on a KubeMQ queue channel with the Elixir SDK in a basic round trip. - How-to guides - [How-to Guides](/docs/sdks/elixir/how-to): Task-oriented recipes for the KubeMQ Elixir SDK — configuration, acks, retries, DLQ, replay, handlers, TLS, and more. - Connection - [Connection Examples](/docs/sdks/elixir/how-to/connection): Client connection, lifecycle, and configuration examples. - [Close a KubeMQ Elixir Client](/docs/sdks/elixir/how-to/connection/close): Manage the KubeMQ client connection lifecycle and close it cleanly using the Elixir SDK. - [Custom Timeouts](/docs/sdks/elixir/how-to/connection/custom-timeouts): Configure custom timeouts and reconnection policies. - [Ping](/docs/sdks/elixir/how-to/connection/ping): Ping the KubeMQ server and display server information. - [Token Auth](/docs/sdks/elixir/how-to/connection/token-auth): Connect to the KubeMQ server with an authentication token using the Elixir SDK client. - Error Handling - [Error Handling Examples](/docs/sdks/elixir/how-to/error-handling): Error handling, reconnection, and graceful shutdown examples. - [Connection Error](/docs/sdks/elixir/how-to/error-handling/connection-error): Handle unreachable KubeMQ servers and validation errors gracefully using the Elixir SDK client. - [Graceful Shutdown](/docs/sdks/elixir/how-to/error-handling/graceful-shutdown): Clean up subscriptions and connections on shutdown. - [Reconnection](/docs/sdks/elixir/how-to/error-handling/reconnection): Connection state monitoring and resilient operations. - Events - [Events Examples](/docs/sdks/elixir/how-to/events): Fire-and-forget event publishing and subscribing examples. - [Cancel Subscription](/docs/sdks/elixir/how-to/events/cancel-subscription): Cancel an active KubeMQ event subscription and stop receiving messages using the Elixir SDK. - [Consumer Group](/docs/sdks/elixir/how-to/events/consumer-group): Load-balance KubeMQ events across subscribers in a consumer group using the Elixir SDK. - [Multiple Subscribers](/docs/sdks/elixir/how-to/events/multiple-subscribers): Fan-out events to multiple independent subscribers. - [Stream Send](/docs/sdks/elixir/how-to/events/stream-send): Send events over a long-lived stream for high throughput. - [Wildcard Subscription](/docs/sdks/elixir/how-to/events/wildcard-subscription): Subscribe to events using wildcard channel patterns. - Events Store - [Events Store Examples](/docs/sdks/elixir/how-to/events-store): Persistent event publishing, subscribing, and replay examples. - [Cancel Subscription](/docs/sdks/elixir/how-to/events-store/cancel-subscription): Cancel an active KubeMQ Events Store subscription and stop receiving events using the Elixir SDK. - [Consumer Group](/docs/sdks/elixir/how-to/events-store/consumer-group): Load-balance persistent event delivery across a consumer group. - [Replay from Sequence](/docs/sdks/elixir/how-to/events-store/replay-from-sequence): Replay KubeMQ Events Store messages starting from a specific sequence number using the Elixir SDK. - [Replay from Time](/docs/sdks/elixir/how-to/events-store/replay-from-time): Replay KubeMQ Events Store messages starting from a specific timestamp using the Elixir SDK. - [Start at Time Delta](/docs/sdks/elixir/how-to/events-store/start-at-time-delta): Replay KubeMQ Events Store messages from a relative time offset in the past using the Elixir SDK. - [Start from First](/docs/sdks/elixir/how-to/events-store/start-from-first): Replay all stored KubeMQ Events Store messages from the beginning of the channel using the Elixir SDK. - [Start from Last](/docs/sdks/elixir/how-to/events-store/start-from-last): Subscribe to a KubeMQ Events Store channel to receive only the most recent stored event, in Elixir. - [Start New Only](/docs/sdks/elixir/how-to/events-store/start-new-only): Subscribe to a KubeMQ Events Store channel to receive only events published after subscribing, in Elixir. - [Stream Send](/docs/sdks/elixir/how-to/events-store/stream-send): Efficiently batch-send persistent events to the KubeMQ Events Store using the Elixir SDK stream API. - [Fan-Out](/docs/sdks/elixir/how-to/fan-out): Distribute messages to multiple independent consumers. - Management - [Management Examples](/docs/sdks/elixir/how-to/management): Channel management operations: create, delete, list, and purge. - [Create Channel](/docs/sdks/elixir/how-to/management/create-channel): Create KubeMQ channels of various types programmatically using the Elixir SDK admin API. - [Delete Channel](/docs/sdks/elixir/how-to/management/delete-channel): Delete an existing KubeMQ channel by name and type using the Elixir SDK admin API. - [List Channels](/docs/sdks/elixir/how-to/management/list-channels): List channels by type with optional search filter. - [Purge Queue](/docs/sdks/elixir/how-to/management/purge-queue): Remove all pending messages from a KubeMQ queue channel using the Elixir SDK admin API. - Observability - [Observability Examples](/docs/sdks/elixir/how-to/observability): Telemetry and observability setup examples for the KubeMQ Elixir SDK, including OpenTelemetry tracing. - [OpenTelemetry Setup](/docs/sdks/elixir/how-to/observability/opentelemetry-setup): Attach handlers to KubeMQ telemetry events to export tracing and metrics using the Elixir SDK. - Queues - [Queues Examples](/docs/sdks/elixir/how-to/queues): Queue messaging examples including send, receive, poll, and stream operations. - [Ack All](/docs/sdks/elixir/how-to/queues/ack-all): Acknowledge all pending KubeMQ queue messages at once using the Elixir SDK poll API. - [Ack Range](/docs/sdks/elixir/how-to/queues/ack-range): Selectively acknowledge specific messages by sequence. - [Ack/Reject](/docs/sdks/elixir/how-to/queues/ack-reject): Selectively acknowledge or reject KubeMQ queue messages via the Elixir SDK poll API. - [Auto Ack](/docs/sdks/elixir/how-to/queues/auto-ack): Automatically acknowledge KubeMQ queue messages on receive using the Elixir SDK. - [Batch Send](/docs/sdks/elixir/how-to/queues/batch-send): Send multiple KubeMQ queue messages in a single batch using the Elixir SDK for higher throughput. - [Dead Letter Policy](/docs/sdks/elixir/how-to/queues/dead-letter-policy): Configure dead-letter routing for failed KubeMQ queue messages via the Elixir SDK stream API. - [Dead Letter Queue](/docs/sdks/elixir/how-to/queues/dead-letter-queue): Route failed KubeMQ queue messages to a dead-letter queue using the Elixir SDK. - [Delay Policy](/docs/sdks/elixir/how-to/queues/delay-policy): Defer KubeMQ queue message delivery via a delay policy on the Elixir SDK stream API. - [Delayed Messages](/docs/sdks/elixir/how-to/queues/delayed-messages): Defer KubeMQ queue message delivery by a specified duration using the Elixir SDK. - [Expiration Policy](/docs/sdks/elixir/how-to/queues/expiration-policy): Expire KubeMQ queue messages after a specified duration using an expiration policy in the Elixir SDK. - [Nack All](/docs/sdks/elixir/how-to/queues/nack-all): Reject all messages in a poll transaction for retry. - [Peek Messages](/docs/sdks/elixir/how-to/queues/peek-messages): Inspect KubeMQ queue contents without consuming messages using the Elixir SDK peek API. - [Poll Mode](/docs/sdks/elixir/how-to/queues/poll-mode): Continuously poll a KubeMQ queue for new messages on demand using the Elixir SDK. - [Requeue All](/docs/sdks/elixir/how-to/queues/requeue-all): Move all received KubeMQ queue messages to a different queue channel at once using the Elixir SDK. - [Stream Receive](/docs/sdks/elixir/how-to/queues/stream-receive): Poll KubeMQ queue messages via the downstream streaming API using the Elixir SDK. - [Stream Send](/docs/sdks/elixir/how-to/queues/stream-send): Send queue messages via upstream bidirectional stream. - [Request-Reply](/docs/sdks/elixir/how-to/request-reply): Implement synchronous request-reply messaging with the KubeMQ Elixir SDK using commands and queries. - RPC - [RPC Examples](/docs/sdks/elixir/how-to/rpc): Command and query examples for synchronous request/response patterns. - [Command Group](/docs/sdks/elixir/how-to/rpc/command-group): Load-balance command processing across a consumer group. - [Handle Command](/docs/sdks/elixir/how-to/rpc/command-handle): Subscribe to handle incoming KubeMQ commands with automatic responses using the Elixir SDK. - [Command Timeout](/docs/sdks/elixir/how-to/rpc/command-timeout): Handle a KubeMQ command timeout when no handler responds in time using the Elixir SDK. - [Cached Query](/docs/sdks/elixir/how-to/rpc/query-cached): Use server-side caching for repeated KubeMQ queries to speed up responses with the Elixir SDK. - [Query Group](/docs/sdks/elixir/how-to/rpc/query-group): Load-balance query processing across a consumer group. - [Handle Query](/docs/sdks/elixir/how-to/rpc/query-handle): Subscribe to process incoming KubeMQ queries and return data responses using the Elixir SDK. - TLS - [TLS & mTLS Examples](/docs/sdks/elixir/how-to/tls): TLS and mutual TLS connection examples for securing KubeMQ client connections with the Elixir SDK. - [mTLS Setup](/docs/sdks/elixir/how-to/tls/mtls-setup): Mutual TLS with client certificate authentication. - [TLS Setup](/docs/sdks/elixir/how-to/tls/tls-setup): Connect to the KubeMQ server with server-side TLS certificate verification using the Elixir SDK. - [Work Queue](/docs/sdks/elixir/how-to/work-queue): Distribute work across competing consumers using a KubeMQ queue and the Elixir SDK for load balancing. - Reference - [Reference](/docs/sdks/elixir/reference): Complete API reference for the KubeMQ Elixir SDK modules, structs, and functions. - [Client](/docs/sdks/elixir/reference/client): KubeMQ.Client GenServer API reference — connection, lifecycle, and all messaging operations for the Elixir SDK. - [Events](/docs/sdks/elixir/reference/events): Event structs and fire-and-forget messaging — KubeMQ Elixir SDK reference. - [Events Store](/docs/sdks/elixir/reference/events-store): Persistent event structs and replay options — KubeMQ Elixir SDK reference. - [Queues](/docs/sdks/elixir/reference/queues): Queue message structs, policies, and pull-based messaging — KubeMQ Elixir SDK reference. - [RPC](/docs/sdks/elixir/reference/rpc): Command and query structs for synchronous request/response — KubeMQ Elixir SDK reference. - [Types & Errors](/docs/sdks/elixir/reference/types-and-errors): Shared types, subscription management, and the KubeMQ.Error exception — Elixir SDK reference. - Connectors - [Connectors](/docs/connectors): KubeMQ's built-in protocol gateways — CloudEvents on the shared HTTP server, plus AMQP, RabbitMQ, AWS, MQTT, STOMP, and GCP wire-protocol connectors. - Concepts - [Observability](/docs/connectors/concepts/observability): Prometheus metrics, OpenTelemetry tracing, and the AI dashboard shared by KubeMQ's HTTP gateways — CloudEvents, plus A2A and MCP (documented under Aiway). - [Shared HTTP Server](/docs/connectors/concepts/shared-http-server): One HTTP server on port 9090 fronts every connector — its middleware chain, the enable model, and reserved channel prefixes. - How-to guides - Migration - [Migration](/docs/connectors/how-to/migration): Pick the right KubeMQ wire-protocol connector for your broker and migrate onto it — the connector map, a cross-protocol matrix, and guides for nine ecosystems. - [Migrating from ActiveMQ](/docs/connectors/how-to/migration/from-activemq): Route ActiveMQ onto KubeMQ by client type — JMS via Qpid JMS, STOMP and MQTT by endpoint; OpenWire is not supported. - [Migrating from AMQP 1.0](/docs/connectors/how-to/migration/from-amqp-1-0): Point a native AMQP 1.0 client at KubeMQ — address-prefix pattern mapping, a go-amqp example, RPC, and the transaction and settlement deviations. - [Migrating from JMS](/docs/connectors/how-to/migration/from-jms): Swap your JMS ConnectionFactory to Apache Qpid JMS over KubeMQ's AMQP 1.0 connector — destination mapping, selectors, a Java example, and the XA gaps. - Reference - [Auth & Security](/docs/connectors/reference/auth-and-security): JWT Bearer authentication, CORS, origin validation, and TLS/mTLS — the security model shared by every KubeMQ connector. - CloudEvents - [CloudEvents](/docs/connectors/cloudevents): Publish and subscribe to KubeMQ over the CNCF CloudEvents HTTP protocol — structured and binary modes, CESQL routing, and SSE replay. - Concepts - [Configuration model](/docs/connectors/cloudevents/concepts/configuration-model): How CloudEvents connector configuration works in KubeMQ — the enabled-by-default model and the CONNECTORSCE_ENABLE env-var derivation rule. - Tutorials - [Getting Started](/docs/connectors/cloudevents/tutorials/getting-started): Publish a CloudEvent and receive it over SSE through the KubeMQ CloudEvents connector in under ten minutes. - How-to guides - [Authentication](/docs/connectors/cloudevents/how-to/authentication): Secure CloudEvents requests with JWT Bearer tokens — publish, subscribe, and ClientID resolution from claims. - [CESQL Routing](/docs/connectors/cloudevents/how-to/cesql-routing): Route CloudEvents by their attributes using CESQL expressions in the KubeMQ routing table, with template substitution and fail-open evaluation. - [Channel Resolution](/docs/connectors/cloudevents/how-to/channel-resolution): Map a CloudEvent to a KubeMQ channel and ClientID using the subject attribute, the channel query parameter, and the source attribute. - [Commands & Queries](/docs/connectors/cloudevents/how-to/commands-queries): Synchronous CloudEvents request-response over HTTP — send commands and queries, correlate responses by request_id. - [Content Modes](/docs/connectors/cloudevents/how-to/content-modes): Send CloudEvents in structured or binary mode over the KubeMQ connector, and understand how the server auto-detects each from the request. - [Events](/docs/connectors/cloudevents/how-to/events): Publish and subscribe to fire-and-forget CloudEvents over HTTP with fan-out delivery and load-balancing consumer groups. - [Events Store](/docs/connectors/cloudevents/how-to/events-store): Publish persistent CloudEvents and subscribe with replay using the six start positions and Last-Event-ID resume over SSE. - [Queues](/docs/connectors/cloudevents/how-to/queues): Send, receive, peek, and ack durable FIFO queue messages over CloudEvents HTTP with the KubeMQ CloudEvents connector. - [SSE Behavior](/docs/connectors/cloudevents/how-to/sse-behavior): Understand the CloudEvents SSE wire format, keepalive, idle timeout, connection limits, and Last-Event-ID reconnection. - Reference - [CE ↔ KubeMQ Mapping](/docs/connectors/cloudevents/reference/ce-to-kubemq-mapping): How CloudEvents attributes map to KubeMQ message tags, channel and ClientID resolution, outbound CE detection, and error codes. - [Configuration](/docs/connectors/cloudevents/reference/configuration): Full field reference for the KubeMQ CloudEvents connector — CeConfig fields, validation rules, and TOML, environment variable, and Docker examples. - [Endpoints](/docs/connectors/cloudevents/reference/endpoints): Reference for every CloudEvents HTTP endpoint — method, path, request, response status, and query parameters. - AMQP 1.0 - [AMQP 1.0](/docs/connectors/amqp): Point an AMQP 1.0 app at KubeMQ by changing only the connection string and node address — all five KubeMQ patterns over the OASIS AMQP 1.0 wire. - Concepts - [Addressing](/docs/connectors/amqp/concepts/addressing): The AMQP 1.0 terminus address grammar — pattern/channel prefixes, channel validation, longest-prefix matching, and dynamic and anonymous nodes. - [Architecture](/docs/connectors/amqp/concepts/architecture): Inside the AMQP 1.0 connector — the amqpmux shared front door, the connection/session/link model, address-to-pattern mapping, and the metadata envelope. - [Commands](/docs/connectors/amqp/concepts/commands): Native AMQP 1.0 request/reply over KubeMQ Commands — dynamic reply nodes, anonymous responders, correlation-id matching, and an executed/error signal. - [Configuration](/docs/connectors/amqp/concepts/configuration): How the KubeMQ AMQP 1.0 connector's opt-in enable flag and DefaultPattern bare-address fallback shape its server-side configuration. - [Events](/docs/connectors/amqp/concepts/events): Fire-and-forget pub/sub over AMQP 1.0 — pre-settled at-most-once fan-out, standing credit, and x-opt-kubemq-group consumer groups on the KubeMQ Events pattern. - [Events Store](/docs/connectors/amqp/concepts/events-store): Durable, replayable pub/sub over AMQP 1.0 — resume a subscription after a disconnect and replay history on the KubeMQ Events Store pattern. - [Queries](/docs/connectors/amqp/concepts/queries): Native AMQP 1.0 request/reply over KubeMQ Queries — fetch a result body over the shared RPC path, with timeouts when no query result is returned. - [Queues](/docs/connectors/amqp/concepts/queues): Durable competing-consumer work queues over AMQP 1.0 — at-least-once delivery, credit-driven consume, and settlement on the KubeMQ Queues pattern. - Tutorials - [Getting Started](/docs/connectors/amqp/tutorials/getting-started): Connect a stock AMQP 1.0 client to KubeMQ and run a send-and-receive round-trip through a KubeMQ Queue in minutes — no KubeMQ SDK required. - How-to guides - [Authentication](/docs/connectors/amqp/how-to/authentication): How an AMQP 1.0 client authenticates to KubeMQ — SASL PLAIN with a KubeMQ JWT, SASL EXTERNAL with mTLS, ANONYMOUS for dev, and Casbin authorization. - [Flow Control](/docs/connectors/amqp/how-to/flow-control): AMQP 1.0 link credit on KubeMQ — who grants credit on produce vs consume links, prefetch and MaxUnsettledPerLink, drain, and pre-settled data-loss footguns. - [Reliability](/docs/connectors/amqp/how-to/reliability): AMQP 1.0 delivery guarantees on KubeMQ — settlement modes, delivery-state to Ack/NAck mapping, at-least-once vs at-most-once, and durable subscriptions. - [TLS and mTLS](/docs/connectors/amqp/how-to/tls-and-mtls): Securing the AMQP 1.0 connector — amqps on port 5671, server-auth TLS vs mutual TLS, and SASL EXTERNAL with the certificate CN as ClientID. - Reference - [Address Mapping](/docs/connectors/amqp/reference/address-mapping): The reference for how an AMQP 1.0 terminus address maps to a KubeMQ pattern and channel — grammar, longest-prefix rules, charset, and anonymous routing. - [Capabilities](/docs/connectors/amqp/reference/capabilities): What the KubeMQ AMQP 1.0 connector advertises, supports, and rejects — the no-capabilities rule, supported features, deterministic rejections, and forced caps. - [Configuration](/docs/connectors/amqp/reference/configuration): Field-by-field reference for the KubeMQ AMQP 1.0 connector's 14 settings, validation rules, and TOML/env/Docker examples. - [Connections & Observability](/docs/connectors/amqp/reference/connections-endpoint): The AMQP 1.0 connector's observability surface — the connections/links detail endpoints, the 11 Prometheus metric families, the SSE group, and audit events. - [Error Conditions](/docs/connectors/amqp/reference/error-conditions): The 13 amqp symbolic error conditions the KubeMQ AMQP 1.0 connector emits — their meanings, triggers, scopes, and recommended client handling. - RabbitMQ (AMQP 0-9-1) - [RabbitMQ (AMQP 0-9-1)](/docs/connectors/rabbitmq): Point a RabbitMQ app at KubeMQ by changing only the connection string — AMQP 0-9-1 over KubeMQ Queues, where every queue is a Queue channel. - Concepts - [Architecture](/docs/connectors/rabbitmq/concepts/architecture): Inside the RabbitMQ (AMQP 0-9-1) connector — the everything-is-a-Queue model, virtual exchange routing, the channel mapping, and cross-protocol interop. - [Configuration](/docs/connectors/rabbitmq/concepts/configuration): How the KubeMQ RabbitMQ (AMQP 0-9-1) connector is configured — enable/disable, TLS, and the availability-first startup model. - [Exchanges and Routing](/docs/connectors/rabbitmq/concepts/exchanges-and-routing): How RabbitMQ exchange types (direct, fanout, topic, headers) work as virtual connector-side routing, resolved at publish time into KubeMQ Queue channels. - Tutorials - [Getting Started](/docs/connectors/rabbitmq/tutorials/getting-started): Connect a stock RabbitMQ client to KubeMQ and run a declare-publish-consume round-trip over a KubeMQ Queue in minutes — no KubeMQ SDK required. - How-to guides - [Authentication](/docs/connectors/rabbitmq/how-to/authentication): How a RabbitMQ (AMQP 0-9-1) client authenticates to KubeMQ — SASL PLAIN with the password as a KubeMQ JWT, the accept-any dev default, and Casbin authorization. - [Pub/Sub (Fanout)](/docs/connectors/rabbitmq/how-to/pub-sub): Broadcast every message to all subscribers over AMQP 0-9-1 — a fanout exchange copies to exclusive queues, each backed by its own KubeMQ Queue channel. - [Queues and Consumers](/docs/connectors/rabbitmq/how-to/queues-and-consumers): Declaring queues, consuming, acknowledging, prefetch (QoS), and basic.get on the KubeMQ RabbitMQ connector — every AMQP queue maps to a KubeMQ Queue channel. - [Reliability](/docs/connectors/rabbitmq/how-to/reliability): Delivery guarantees on the KubeMQ RabbitMQ connector — publisher confirms, mandatory/return, dead-letter exchanges, per-message TTL, and at-least-once delivery. - [Routing (Direct)](/docs/connectors/rabbitmq/how-to/routing): Selective delivery over AMQP 0-9-1 — a direct exchange routes by exact routing-key match, unmatched keys dropped, resolved onto KubeMQ Queue channels. - [RPC (Direct Reply-To)](/docs/connectors/rabbitmq/how-to/rpc): Native in-protocol request/reply over AMQP 0-9-1 — amq.rabbitmq.reply-to with correlation-id, the responder a plain AMQP consumer on a KubeMQ Queue. - [TLS and mTLS](/docs/connectors/rabbitmq/how-to/tls-and-mtls): Securing the KubeMQ RabbitMQ connector — amqps on port 5671 via the server Security block, server-auth and mutual TLS, and encrypting the JWT in the password. - [Topics](/docs/connectors/rabbitmq/how-to/topics): Pattern-based routing over AMQP 0-9-1 — a topic exchange matches dot-separated routing keys with * and - [Work Queues](/docs/connectors/rabbitmq/how-to/work-queues): Distribute time-consuming tasks across competing workers over AMQP 0-9-1 — durable queues, manual ack, prefetch, and at-least-once delivery on the KubeMQ Queue. - Reference - [Capabilities](/docs/connectors/rabbitmq/reference/capabilities): What the KubeMQ RabbitMQ (AMQP 0-9-1) connector supports, the caps it negotiates, the methods it rejects, the inert arguments it accepts, and the nine gotchas. - [Channel Mapping](/docs/connectors/rabbitmq/reference/channel-mapping): The reference for how a RabbitMQ AMQP 0-9-1 queue maps to a KubeMQ Queue channel — the amqp.{vhost}.{queue} grammar, charset, and property/header mapping. - [Configuration reference](/docs/connectors/rabbitmq/reference/configuration): The 12-field CONNECTORS_AMQP_* environment variable table and validation rules for the KubeMQ RabbitMQ (AMQP 0-9-1) connector. - [Connections & Observability](/docs/connectors/rabbitmq/reference/connections-endpoint): The RabbitMQ (AMQP 0-9-1) connector's observability surface — the connections and topology endpoints, Prometheus metrics, the SSE feed, and audit events. - [Error & Reason Codes](/docs/connectors/rabbitmq/reference/error-codes): The AMQP 0-9-1 channel and connection close codes (311–541) the KubeMQ RabbitMQ connector returns — their meanings, triggers, and channel-vs-connection scope. - [Migrating from RabbitMQ](/docs/connectors/rabbitmq/reference/migration-from-rabbitmq): Point a RabbitMQ app at KubeMQ by changing only the AMQP 0-9-1 connection string — exchanges, DLX, confirms, and the connector deviations. - AWS (SQS & SNS) - [AWS (SQS & SNS)](/docs/connectors/aws): Point an AWS SQS / SNS app at KubeMQ by changing only the endpoint URL — SQS over KubeMQ Queues and virtual SNS fan-out on a dedicated HTTP listener. - Concepts - [Architecture](/docs/connectors/aws/concepts/architecture): Inside the KubeMQ AWS connector — one binary with two service surfaces, SQS as a KubeMQ Queue channel, the virtual SNS registry, and cross-protocol interop. - [Configuration](/docs/connectors/aws/concepts/configuration): Why the KubeMQ AWS connector is opt-in, how CONNECTORS_AWS_ENABLE opens port 4566, and the accept-any vs static credential postures. - [Cross-Protocol Interop](/docs/connectors/aws/concepts/cross-protocol-interop): Share an sqs.* channel between an AWS SDK app and a native KubeMQ gRPC/REST client — produce with boto3, consume with kubemq-go, and migrate one side at a time. - Tutorials - [Getting Started](/docs/connectors/aws/tutorials/getting-started): Enable the KubeMQ AWS connector, point a standard AWS SDK at port 4566, and run an SQS send-and-receive round-trip in minutes — no LocalStack, no KubeMQ SDK. - How-to guides - [Authentication](/docs/connectors/aws/how-to/authentication): How the AWS connector authenticates SQS and SNS requests — SigV4 verification, the accept-any local-dev default, static credentials, and Casbin authorization. - [Connectivity and security](/docs/connectors/aws/how-to/connectivity-and-security): How AWS SDK clients reach the connector — the port 4566 endpoint override, the CONNECTORS_AWS_ENABLE flag, path-style URLs, SigV4, and the region/account model. - [Fan-Out (SNS → SQS)](/docs/connectors/aws/how-to/fan-out): One SNS publish, many consumers over KubeMQ — fan out a single message to subscribed SQS queues and HTTP/HTTPS webhooks, with MessageAttributes filtering. - [Reliability](/docs/connectors/aws/how-to/reliability): Reliability across the AWS connector SQS and SNS surfaces — visibility timeouts, FIFO ordering, DLQ/redrive, the SNS retry pipeline, and at-least-once delivery. - [SNS fan-out](/docs/connectors/aws/how-to/sns-fan-out): The AWS connector's SNS surface — virtual topics, SQS and HTTP/HTTPS subscriptions, the confirmation flow, MessageAttributes filtering, PublishBatch, and FIFO. - [SNS Topics](/docs/connectors/aws/how-to/sns-topics): Create, subscribe, and publish to AWS SNS topics over KubeMQ — virtual topics with MessageAttributes filtering, PublishBatch, and FIFO fan-out to SQS queues. - [SQS Queues](/docs/connectors/aws/how-to/sqs-queues): Point an AWS SQS app at KubeMQ — send, receive, batch, visibility timeout, FIFO, and DLQ redrive, mapped onto the KubeMQ Queues pattern on sqs.{name} channels. - [SQS queues and consumers](/docs/connectors/aws/how-to/sqs-queues-and-consumers): The AWS connector SQS surface end to end — queue lifecycle, send/receive/delete, visibility timeouts, long polling, batch operations, and DLQ/redrive. - Reference - [Capabilities](/docs/connectors/aws/reference/capabilities): What the KubeMQ AWS (SQS & SNS) connector supports — the 18 SQS and 17 SNS actions, the queue and topic attributes, and the out-of-scope operations it rejects. - [Channel Mapping](/docs/connectors/aws/reference/channel-mapping): How an AWS SQS queue maps to a KubeMQ Queue channel — the sqs.{name} grammar, FIFO message-group encoding, the virtual SNS registry, and the tag codec. - [Configuration](/docs/connectors/aws/reference/configuration): Reference table of the ten CONNECTORS_AWS_* environment variables for the KubeMQ AWS connector, with TOML, Env, and Docker equivalents. - [Connections & Observability](/docs/connectors/aws/reference/connections-endpoint): The AWS connector's observability surface — the read-only management API, the Prometheus metrics, the dashboard page, and the audit events it emits. - [Error Codes](/docs/connectors/aws/reference/error-codes): The genuine AWS SQS/SNS error codes the KubeMQ AWS connector returns over the AWS JSON and Query wire protocols, with HTTP status, trigger, and scenarios. - [Migrating from AWS SQS/SNS](/docs/connectors/aws/reference/migration-from-aws): Override the AWS SDK endpoint to KubeMQ — SQS, SNS fan-out, FIFO, and redrive DLQ migrate; email/SMS/Lambda do not. - Google Cloud Pub/Sub - [Google Cloud Pub/Sub](/docs/connectors/gcp-pub-sub): Point an unmodified Google Cloud Pub/Sub app at KubeMQ by setting PUBSUB_EMULATOR_HOST and run topics and subscriptions over the embedded gRPC connector. - Concepts - [Architecture](/docs/connectors/gcp-pub-sub/concepts/architecture): Inside the KubeMQ Pub/Sub connector — the gRPC emulator listener, the 38-RPC surface, and how topics and subscriptions map to Events Store logs and Queues. - [Configuration](/docs/connectors/gcp-pub-sub/concepts/configuration): How the KubeMQ GCP Pub/Sub connector is enabled, secured, and configured — a server-side, opt-in gRPC emulator. - [Cross-Protocol Interop](/docs/connectors/gcp-pub-sub/concepts/cross-protocol-interop): Publish with a Google Pub/Sub SDK and consume natively with a KubeMQ client on the Events Store log gcp.{topic}, carrying the reserved _pubsub_* tags across. - Tutorials - [Getting Started](/docs/connectors/gcp-pub-sub/tutorials/getting-started): Connect a Google Cloud Pub/Sub SDK to KubeMQ on gRPC port 8085 via PUBSUB_EMULATOR_HOST, then run a publish, pull, and acknowledge round-trip in minutes. - How-to guides - [Connectivity and emulator mode](/docs/connectors/gcp-pub-sub/how-to/connectivity-and-emulator-mode): How a Google Pub/Sub SDK reaches the connector — the PUBSUB_EMULATOR_HOST drop-in, per-language emulator opt-in, insecure gRPC, and the cluster caveat. - [Fan-Out](/docs/connectors/gcp-pub-sub/how-to/fan-out): One publish, many subscriptions over KubeMQ — fan a Pub/Sub topic message out to independent subscriptions on gcp.sub.{s} queues, each with its own ack state. - [Message filtering](/docs/connectors/gcp-pub-sub/how-to/filtering): Subscription-level attribute filtering over KubeMQ — the CEL-subset grammar, the ≤ 256-char immutable rule, and how filters apply at publish fan-out. - [Ordered Delivery](/docs/connectors/gcp-pub-sub/how-to/ordered-delivery): Per-key in-order delivery with Pub/Sub ordering keys over KubeMQ — enable ordering, publish with an ordering key, consume at-most-one-in-flight per key. - [Publish & Subscribe](/docs/connectors/gcp-pub-sub/how-to/publish-subscribe): Create a topic and a subscription, publish a message, then pull and acknowledge it over KubeMQ — the core Pub/Sub round-trip on gcp.{topic} channels. - [Publishing](/docs/connectors/gcp-pub-sub/how-to/publishing): Create topics and publish over KubeMQ — single and batch Publish, server-assigned ids and publish time, ordering keys, and the publish-once-fan-out model. - [Push Delivery](/docs/connectors/gcp-pub-sub/how-to/push-delivery): Push subscriptions over KubeMQ — the per-subscription delivery worker, wrapped JSON envelope vs no_wrapper, 2xx-acks, retry with backoff, and dead-letter. - [Reliability](/docs/connectors/gcp-pub-sub/how-to/reliability): Delivery guarantees over KubeMQ — dead-letter topics, retry backoff, at-least-once redelivery, node-local exactly-once, and retention clamped to the broker. - [Schema Validation](/docs/connectors/gcp-pub-sub/how-to/schema-validation): Avro and Protobuf schema enforcement over KubeMQ — CreateSchema, topic schema_settings, enforce-on-publish, ≤300 KB definitions, and revisions. - [Seek & Snapshots](/docs/connectors/gcp-pub-sub/how-to/seek-and-snapshots): Replay over KubeMQ — Seek to a timestamp or snapshot, replay bounded by MaxSeekReplay, pre-window timestamps clamped to earliest, and snapshot expiry. - [Subscribing](/docs/connectors/gcp-pub-sub/how-to/subscribing): Consume over KubeMQ — Pull vs StreamingPull with flow control, ack-deadline leases, ModifyAckDeadline nack/extend, and exactly-once with its node-local note. - Reference - [Capabilities](/docs/connectors/gcp-pub-sub/reference/capabilities): What the KubeMQ Pub/Sub connector supports — the 38 v1 RPCs across Publisher, Subscriber, SchemaService, and IAMPolicy stubs, and the operations it rejects. - [Channel Mapping](/docs/connectors/gcp-pub-sub/reference/channel-mapping): How Pub/Sub topics and subscriptions map to KubeMQ — the gcp.{topic} Events Store log, the gcp.sub.{subscription} Queue grammar, reserved tags, and project. - [Configuration reference](/docs/connectors/gcp-pub-sub/reference/configuration): The thirteen CONNECTORS_GCP_* environment variables for the KubeMQ Pub/Sub connector, with defaults and TOML/env/Docker examples. - [Connections & Observability](/docs/connectors/gcp-pub-sub/reference/connections-endpoint): The Pub/Sub connector's observability surface — the read-only management view, Prometheus metrics, the dashboard page, and the audit events it emits. - [Error Codes](/docs/connectors/gcp-pub-sub/reference/error-codes): The gRPC status codes the KubeMQ Pub/Sub connector returns — the exactly-once invalid-ack FAILED_PRECONDITION deviation and common INVALID_ARGUMENT triggers. - [Limits & Rules](/docs/connectors/gcp-pub-sub/reference/limits-and-rules): The numeric limits — ack deadline 10..600s, max_delivery_attempts 5..100, filter ≤256 chars, schema ≤300 KB, batch ≤1000, and CONNECTORS_GCP_* caps. - [Migrating from Google Cloud Pub/Sub](/docs/connectors/gcp-pub-sub/reference/migration-from-gcp): Set PUBSUB_EMULATOR_HOST to KubeMQ — topics and subscriptions map; no auth/TLS, ordering is node-local. - MQTT - [MQTT](/docs/connectors/mqtt): Point your MQTT 3.1.1 / 5.0 app at KubeMQ by changing only the broker address — all five KubeMQ patterns over the native MQTT wire on ports 1883 / 8883 / 8083. - Concepts - [Architecture](/docs/connectors/mqtt/concepts/architecture): Inside the MQTT connector — the embedded broker, the bridge hook, the topic mapper, topic-to-pattern mapping, wildcard translation, and cross-protocol interop. - [Configuration](/docs/connectors/mqtt/concepts/configuration): How the KubeMQ MQTT connector is enabled, why capabilities are forced, and how TLS is derived from server Security config. - [Protocol versions](/docs/connectors/mqtt/concepts/protocol-versions): MQTT 3.1.1 vs MQTT 5.0 on the KubeMQ connector — the feature matrix, what is 5.0-only (RPC, $share Queue consume, User Properties), and why 3.1 is rejected. - [QoS and sessions](/docs/connectors/mqtt/concepts/qos-and-sessions): QoS 0/1/2 on the KubeMQ MQTT connector — the QoS each pattern requires, ack-on-PUBACK for Queues, node-local sessions, and why retain is silently dropped. - [Topic mapping](/docs/connectors/mqtt/concepts/topic-mapping): How the KubeMQ MQTT connector maps topics to patterns and channels — the prefix grammar, slash-to-dot, wildcards, $share consume, and $reply RPC replies. - Tutorials - [Getting Started](/docs/connectors/mqtt/tutorials/getting-started): Connect a stock MQTT client to KubeMQ and run a publish-and-subscribe round-trip over the Events pattern in minutes — no KubeMQ SDK required. - How-to guides - [Authentication](/docs/connectors/mqtt/how-to/authentication): How an MQTT client authenticates to KubeMQ — password-as-JWT in the CONNECT packet, ClientID as identity, ACL authorization, and the open no-auth default. - [Commands](/docs/connectors/mqtt/how-to/commands): RPC with execution acknowledgement over MQTT 5.0 — the commands/ prefix, $reply response topics, correlation data, and the kubemq-executed pass/fail signal. - [Events](/docs/connectors/mqtt/how-to/events): Fire-and-forget MQTT pub/sub over KubeMQ Events — the events/ topic prefix, +/# wildcard subscriptions, User-Properties as Tags, and the dropped retain flag. - [Events Store](/docs/connectors/mqtt/how-to/events-store): Persistent MQTT pub/sub over KubeMQ Events Store — the store/ topic prefix, durable storage, and the StartNewOnly constraint with no historical replay. - [Queries](/docs/connectors/mqtt/how-to/queries): RPC with a data response over MQTT 5.0 — the queries/ prefix, $reply response topics, correlation data, and a response body plus kubemq-metadata. MQTT 5.0 only. - [Queues](/docs/connectors/mqtt/how-to/queues): Durable competing-consumer work queues over MQTT — publish-only produce on queues/, $share consume (MQTT 5.0 only), and the ack-on-PUBACK redelivery model. - [TLS and WebSocket](/docs/connectors/mqtt/how-to/tls-and-websocket): Securing and transporting the KubeMQ MQTT connector — plain TCP on 1883, TLS on 8883, WebSocket on 8083, the URL-scheme selector, mTLS, and disabling listeners. - Reference - [Capabilities](/docs/connectors/mqtt/reference/capabilities): What the KubeMQ MQTT connector advertises to clients — the three forced capabilities, configurable limits, protocol-version support, and session semantics. - [Configuration](/docs/connectors/mqtt/reference/configuration): Reference for the KubeMQ MQTT connector config fields, capability fields, forced capabilities, validation rules, and TOML/env/Docker examples. - [Connections Endpoint](/docs/connectors/mqtt/reference/connections-endpoint): The KubeMQ MQTT connector's observability surface — the node-local connections snapshot endpoint, its JSON schema, and the three Prometheus metrics. - [Reason Codes](/docs/connectors/mqtt/reference/reason-codes): Every MQTT 5.0 reason code the KubeMQ MQTT connector produces — the packet it appears on, what it means, the exact triggers, and how MQTT 3.1.1 behaves instead. - [Topic Grammar](/docs/connectors/mqtt/reference/topic-grammar): How the KubeMQ MQTT connector maps every topic and filter to a pattern and channel — prefixes, slash-to-dot, wildcards, shared subscriptions, and RPC replies. - Scenarios - [Migrating from MQTT](/docs/connectors/mqtt/scenarios/migration): Move an MQTT 3.1.1 / 5.0 app to KubeMQ by swapping the broker host — what carries over, topic-prefix mapping onto KubeMQ patterns, and what does not migrate. - STOMP - [STOMP](/docs/connectors/stomp): Point a STOMP app at KubeMQ by changing only the broker address — all five KubeMQ patterns over the STOMP 1.0/1.1/1.2 wire, selected by destination prefix. - Concepts - [Architecture](/docs/connectors/stomp/concepts/architecture): Inside the STOMP connector — the embedded STOMP server, the frame codec, version negotiation, handler dispatch, and the destination → pattern → channel router. - [Configuration](/docs/connectors/stomp/concepts/configuration): How the STOMP connector's opt-in enable flag, DefaultPattern, ports, and TLS behavior fit together in KubeMQ. - Tutorials - [Getting Started](/docs/connectors/stomp/tutorials/getting-started): Connect a stock STOMP client to KubeMQ and run a publish-and-subscribe round-trip over the Events pattern in minutes — no KubeMQ SDK required. - How-to guides - [Ack modes and receipts](/docs/connectors/stomp/how-to/ack-modes-and-receipts): STOMP delivery reliability on KubeMQ — the auto, client-individual, and client ack modes, ACK/NACK correlation, the 30s requeue timeout, and RECEIPT frames. - [Authentication](/docs/connectors/stomp/how-to/authentication): How a STOMP client authenticates to KubeMQ — the CONNECT login/passcode frame, passcode as a KubeMQ JWT, session ids, and per-channel Casbin authorization. - [Commands](/docs/connectors/stomp/how-to/commands): Requester-only RPC commands over STOMP — the /command/ destination prefix, the 3-step reply-to flow, and the stomp-error failure header on KubeMQ Commands. - [Connectivity and security](/docs/connectors/stomp/how-to/connectivity-and-security): Connecting a STOMP client to KubeMQ — the KUBEMQ_STOMP_URL convention, ports 61613/61614, the CONNECT handshake, heartbeats, and TLS on 61614. - [Destination mapping](/docs/connectors/stomp/how-to/destination-mapping): How the KubeMQ STOMP connector maps a destination to a pattern and channel — the prefix grammar, slash-to-dot joining, aliases, and Events-only wildcards. - [Events](/docs/connectors/stomp/how-to/events): Fire-and-forget STOMP pub/sub over KubeMQ Events — the /topic/ destination prefix, fan-out delivery, native wildcards (* and >), and at-most-once semantics. - [Events Store](/docs/connectors/stomp/how-to/events-store): Persistent STOMP pub/sub over KubeMQ Events Store — the /topic-store/ prefix, the replay headers, and replaying history from first, last, a sequence, or a time. - [Protocol versions](/docs/connectors/stomp/how-to/protocol-versions): STOMP 1.0/1.1/1.2 on the KubeMQ connector — version negotiation from accept-version, the per-version feature matrix, header escaping, and ack token rules. - [Queries](/docs/connectors/stomp/how-to/queries): Requester-only RPC queries over STOMP — the /query/ destination prefix and the 3-step reply-to flow that returns a response body and tags on KubeMQ Queries. - [Queues](/docs/connectors/stomp/how-to/queues): Competing-consumer work queues over STOMP — the /queue/ destination prefix, three ack modes, at-least-once delivery, and the KubeMQ Queues pattern. - Reference - [Capabilities](/docs/connectors/stomp/reference/capabilities): What the KubeMQ STOMP connector supports and rejects — protocol versions, client commands, ack modes, hard-rejected features, and reliability guarantees. - [Configuration](/docs/connectors/stomp/reference/configuration): Reference for the 11 CONNECTORS_STOMP_* environment variables and the startup validation rules for the KubeMQ STOMP connector. - [Connections & Observability](/docs/connectors/stomp/reference/connections-endpoint): The STOMP connector's observability surface — the management API, the three Prometheus series, the web dashboard, and the audit taxonomy for verifying STOMP. - [Destination Grammar](/docs/connectors/stomp/reference/destination-grammar): How a STOMP destination maps to a KubeMQ (pattern, channel) pair — primary prefixes and aliases, slash-to-dot joining, wildcards, and header-to-tag tables. - [Error Frames](/docs/connectors/stomp/reference/error-frames): The complete ERROR-frame vocabulary the KubeMQ STOMP connector emits — handshake, codec, dispatch, SEND, SUBSCRIBE, and RPC errors, plus receipt rules. - Scenarios - [Migrating from STOMP](/docs/connectors/stomp/scenarios/migration-from-stomp): Change the STOMP broker host to KubeMQ — every destination type maps; no transactions or selectors. - Kafka - [Kafka](/docs/connectors/kafka): Point unmodified Kafka clients at KubeMQ over the native wire protocol — produce, consume, consumer groups, and compaction, with no client-library swap. - Concepts - [Architecture](/docs/connectors/kafka/concepts/architecture): How the Kafka drop-in connector works — the 9092/9093 wire-protocol listeners, Produce/Fetch/group-coordinator dispatch, and the Events Store log mapping. - [Configuration](/docs/connectors/kafka/concepts/configuration): How the Kafka connector is enabled, ported, and secured — the opt-in CONNECTORS_KAFKA_ENABLE flag, the 9092/9093 listeners, and the settings reference. - [Consumer Groups](/docs/connectors/kafka/concepts/consumer-groups): Consumer groups on KubeMQ — JoinGroup/SyncGroup/Heartbeat coordination, durable per-group offsets, generations, rebalancing, and static membership (KIP-345). - [Partitions & Ordering](/docs/connectors/kafka/concepts/partitions-and-ordering): The Kafka partition model on KubeMQ — 1..256 increase-only partitions, client-side key hashing (murmur2 vs CRC32), and the per-partition ordering guarantee. - [Durability & Retention](/docs/connectors/kafka/concepts/durability-and-retention): How Kafka durability maps to KubeMQ — the acks 0/1/all contract, quorum-fsynced zero-acked-loss, retention by time and size, and log compaction. - Tutorials - [Getting Started](/docs/connectors/kafka/tutorials/getting-started): Enable the Kafka connector, then produce and consume your first message over the wire protocol with kcat and seven client libraries — a full round-trip. - How-to guides - [Producing](/docs/connectors/kafka/how-to/producing): Produce to KubeMQ over the Kafka protocol — message keys and headers, the acks durability setting, batching, and the idempotent producer. - [Consuming](/docs/connectors/kafka/how-to/consuming): Consume from KubeMQ over the Kafka protocol — join a consumer group, commit offsets manually or automatically, and seek by offset or timestamp. - [Compacted Topics](/docs/connectors/kafka/how-to/compacted-topics): Run log-compacted topics on KubeMQ — set cleanup.policy=compact, understand tombstones and latest-value-per-key retention, and the ecosystems it unlocks. - [Transactions & EOS](/docs/connectors/kafka/how-to/transactions): Exactly-once semantics on KubeMQ — the transactional producer, read_committed isolation, consume-transform-produce, and producer fencing. - [Share Groups](/docs/connectors/kafka/how-to/share-groups): Queue-style consumption with Kafka share groups (KIP-932) on KubeMQ, in preview — per-record acquire and acknowledge, and how it differs from consumer groups. - [Authentication](/docs/connectors/kafka/how-to/authentication): Authenticate Kafka clients to KubeMQ — SASL/PLAIN and SCRAM, OAUTHBEARER/OIDC federated tokens, mTLS client certificates, and the ACL authorization model. - [TLS and mTLS](/docs/connectors/kafka/how-to/tls-and-mtls): Secure the Kafka connector with TLS — the 9093 encrypted listener, server certificates, and mutual TLS where the certificate common name is the principal. - [Migrate from Kafka](/docs/connectors/kafka/how-to/migrate-from-kafka): Assess fit with kmq assess kafka, then move topics and consumer-group offsets to KubeMQ with the kmq migrate tool. - Reference - [Capabilities](/docs/connectors/kafka/reference/capabilities): What the KubeMQ Kafka connector supports — every implemented Kafka API, from Produce/Fetch and consumer groups to transactions and share groups (preview). - [Configuration reference](/docs/connectors/kafka/reference/configuration): The Kafka connector settings at a glance — the opt-in flag, the 9092/9093 ports, and TOML/environment/Docker examples, plus the full settings reference. - [Connections & Observability](/docs/connectors/kafka/reference/connections-endpoint): The Kafka connector's observability surface — the /api/kafka/* dashboard endpoints, Prometheus metric families, and the per-connection principal view. - [Topic Mapping](/docs/connectors/kafka/reference/topic-mapping): How Kafka topics, partitions, and offsets map to KubeMQ — the kafka.{topic} Events Store log, the ~{partition} suffix, and the offset-to-Sequence off-by-one. - [Error Codes](/docs/connectors/kafka/reference/error-codes): The Kafka protocol error codes the connector returns — UNSUPPORTED_VERSION, INVALID_PARTITIONS, transaction and authorization codes, and MESSAGE_TOO_LARGE. - [Limits & Rules](/docs/connectors/kafka/reference/limits-and-rules): The Kafka connector's numeric limits — 256 partitions per topic, the 1 MiB default message ceiling, connection and consumer-group caps, and offset retention. - [Fitness matrix](/docs/connectors/kafka/reference/fitness-matrix): What's drop-in, supported, roadmap, and unsupported when running Kafka workloads on KubeMQ (T1–T4). - Integrations - [Integrations](/docs/integrations): Framework and platform adapters that wire KubeMQ into your stack — NestJS, Spring, Celery, Ray Serve, KEDA, and more — all on the gRPC SDK. - NestJS - [NestJS](/docs/integrations/nestjs): A custom NestJS transport wiring all five KubeMQ messaging patterns into the microservices ecosystem with idiomatic decorators, a CQRS bridge, and DI. - Concepts - [NestJS Transport Concepts](/docs/integrations/nestjs/concepts): Understand how the transport maps NestJS microservice primitives onto KubeMQ's five messaging patterns. - [CQRS Bridge Concepts](/docs/integrations/nestjs/concepts/cqrs-bridge): How the NestJS CQRS bridge routes @nestjs/cqrs CommandBus, QueryBus, and EventBus traffic over KubeMQ channels. - Tutorials - [Getting Started with NestJS](/docs/integrations/nestjs/tutorials/getting-started): Install the transport and build a first end-to-end NestJS app that sends and handles a KubeMQ command in under 5 minutes. - How-to guides - [Configuration & Resilience](/docs/integrations/nestjs/how-to/configuration-and-resilience): Configure TLS/auth, reconnection, custom serialization, DLQ routing, validation, idempotency, and a circuit breaker for production handlers. - [Set Up the CQRS Bridge](/docs/integrations/nestjs/how-to/cqrs-bridge): Install and configure the NestJS CQRS bridge to route @nestjs/cqrs commands, queries, and events through KubeMQ. - [Module Configuration](/docs/integrations/nestjs/how-to/module-configuration): Wire the transport into NestJS DI with forRoot, register, async factories, multi-broker, and forFeature scoped clients. - [Testing](/docs/integrations/nestjs/how-to/testing): Unit-test services and handlers without a live broker using MockKubeMQClient, MockKubeMQServer, and KubeMQModule.forTest(). - [Usage](/docs/integrations/nestjs/how-to/usage): Send and handle Commands, Queries, Events, Events Store, and Queues from NestJS using the five handler decorators and the KubeMQRecord builder. - Reference - [API](/docs/integrations/nestjs/reference/api): The @kubemq/nestjs-transport API surface — KubeMQModule static methods, the five handler decorators, the request/queue contexts, codecs, and constants. - [Configuration](/docs/integrations/nestjs/reference/configuration): Connection options and every configuration interface for @kubemq/nestjs-transport — KubeMQServerOptions, KubeMQClientOptions, and KubeMQCqrsOptions. - [KubeMQCqrsOptions](/docs/integrations/nestjs/reference/cqrs-options): Full field reference for KubeMQCqrsModule.forRoot() options that route NestJS CQRS commands, queries, and events through KubeMQ. - [Error Codes](/docs/integrations/nestjs/reference/error-codes): The exported error types of @kubemq/nestjs-transport, the KubeMQRpcException shape, and a troubleshooting / FAQ table. - Spring Boot - [Spring Boot](/docs/integrations/spring-boot): Integrate KubeMQ into Spring Boot and Spring Cloud Stream applications with auto-configuration, a messaging template, and annotation-driven listeners. - Concepts - [Spring Boot Concepts](/docs/integrations/spring-boot/concepts): Understand the auto-configuration model, KubeMQTemplate, annotation-driven listeners, and how the integration's modules fit together. - Tutorials - [Getting Started with Spring Boot](/docs/integrations/spring-boot/tutorials/getting-started): Add the KubeMQ starter, configure it, and run your first end-to-end publish-and-subscribe example in a Spring Boot app. - How-to guides - [Commands & Queries](/docs/integrations/spring-boot/how-to/commands-and-queries): Synchronous request-response (RPC) messaging using KubeMQTemplate and the @KubeMQCommandHandler / @KubeMQQueryHandler annotations. - [Configure Connection, TLS, and Observability](/docs/integrations/spring-boot/how-to/configure-connection-tls-observability): Tune the gRPC connection, enable TLS/mTLS and auth tokens, and wire up health checks and Micrometer metrics. - [Events & Events Store](/docs/integrations/spring-boot/how-to/events-and-events-store): Publish and subscribe to fire-and-forget events and replayable persistent events using KubeMQTemplate and listener annotations. - [Kotlin](/docs/integrations/spring-boot/how-to/kotlin): Coroutine suspend extensions, Flow-based subscriptions, suspend listener support, and the kubemq { } configuration DSL from the Kotlin starter module. - [Queues](/docs/integrations/spring-boot/how-to/queues): Durable point-to-point messaging with polling listeners, acknowledgment, visibility timeout, batching, and dead-letter handling. - [Spring Cloud Stream Binder](/docs/integrations/spring-boot/how-to/spring-cloud-stream-binder): Use the KubeMQ Spring Cloud Stream binder to wire functional bindings to Events, Events Store, and Queues channels. - [Test KubeMQ Spring Applications](/docs/integrations/spring-boot/how-to/testing): Write fast, broker-free tests with MockKubeMQServer or full integration tests with TestContainers using the @KubeMQTest annotation. - Reference - [API Reference](/docs/integrations/spring-boot/reference/api): The KubeMQTemplate send API, the five listener and handler annotations, the Spring Cloud Stream binder properties, and the Actuator endpoints. - [Configuration Reference](/docs/integrations/spring-boot/reference/configuration): Every kubemq.* property for the Spring Boot starter — connection, TLS, listeners, template, health, metrics, and Kotlin — with types and defaults. - MassTransit - [MassTransit](/docs/integrations/masstransit): Run MassTransit .NET apps over KubeMQ — a drop-in transport mapping Send, Publish, and request/response to native Queues, Events, EventsStore, and CQ. - Concepts - [MassTransit Concepts](/docs/integrations/masstransit/concepts): Understand how MassTransit messaging patterns map onto native KubeMQ patterns, channel naming, header mapping, and the rider-based transport architecture. - Tutorials - [Getting Started with MassTransit](/docs/integrations/masstransit/tutorials/getting-started): Install the MassTransit.KubeMQ transport and run your first publish/subscribe and queue example end-to-end against a local KubeMQ broker. - How-to guides - [Commands & Queries (Request/Response)](/docs/integrations/masstransit/how-to/commands-queries): Map MassTransit request/response to KubeMQ's native Commands/Queries (CQ) — no temporary reply queues — with CqMode selection and timeouts. - [Configuration](/docs/integrations/masstransit/how-to/configuration): Configure the KubeMQ host, auth, TLS, timeouts, and poll behavior for the MassTransit.KubeMQ transport via code, kubemq:// URIs, or appsettings.json. - [Error Handling & Dead-Lettering](/docs/integrations/masstransit/how-to/error-handling-dlq): Handle faulted and skipped messages with KubeMQ error/skipped channels, native DLQ via MaxReceiveCount, retry policies, and message expiration. - [Events (Publish)](/docs/integrations/masstransit/how-to/events): Map MassTransit Publish to KubeMQ Events for fire-and-forget fan-out — UseVolatileEvents, PublishEventAsync, consumer groups, and volatile delivery. - [Events Store (Durable Publish)](/docs/integrations/masstransit/how-to/events-store): Enable persistent, replayable fan-out by routing MassTransit Publish through KubeMQ EventsStore, with configurable subscription start positions. - [Migrating from Other Transports](/docs/integrations/masstransit/how-to/migration): Migrate an existing MassTransit application from RabbitMQ, Azure Service Bus, or Amazon SQS to the KubeMQ transport with minimal code changes. - [Observability](/docs/integrations/masstransit/how-to/observability): Wire up ASP.NET Core health checks, OpenTelemetry distributed tracing, and the MassTransit.KubeMQ metrics meter for the transport. - [Queues (Send)](/docs/integrations/masstransit/how-to/queues): Map MassTransit Send to KubeMQ Queues for durable point-to-point delivery — delayed send, TTL, batch consumers, priority queues, and competing consumers. - Reference - [API Reference](/docs/integrations/masstransit/reference/api): MassTransit.KubeMQ registration entry points and the bus-factory, host, receive-endpoint, transport, and priority-queue configurator interfaces. - [Configuration Reference](/docs/integrations/masstransit/reference/configuration): The MassTransit.KubeMQ transport options POCO, validation rules, appsettings binding, host URI scheme, channel naming, and header/tag mapping. - [Error Codes](/docs/integrations/masstransit/reference/error-codes): The MassTransit.KubeMQ transport exception hierarchy, validation error messages, and the triggers behind connection, timeout, and CQ request failures. - FastStream - [FastStream](/docs/integrations/faststream): KubeMQ broker adapter for the FastStream async messaging framework, with native support for all five KubeMQ messaging patterns. - Concepts - [Concepts](/docs/integrations/faststream/concepts/concepts): How KubeMQBroker maps the five KubeMQ patterns onto three SDK clients, its connection lifecycle, and the FastStream pipeline that runs every message. - Tutorials - [Getting Started with FastStream](/docs/integrations/faststream/tutorials/getting-started): Install kubemq-faststream, start a broker, and build your first end-to-end KubeMQ FastStream app in minutes. - How-to guides - [Commands & Queries (RPC)](/docs/integrations/faststream/how-to/commands-queries): Request-reply RPC with KubeMQ FastStream — commands return execution status, queries return data with optional caching. - [Routers & Publishers](/docs/integrations/faststream/how-to/composition): Compose modular KubeMQ FastStream apps with KubeMQRouter and auto-publish handler outputs with @broker.publisher. - [Configuration & Security](/docs/integrations/faststream/how-to/configuration): Configure the KubeMQ broker connection via constructor options, environment variables, URL schemes, TLS/mTLS, and auth tokens. - [Events (Pub/Sub)](/docs/integrations/faststream/how-to/events): Fire-and-forget pub/sub messaging with KubeMQ FastStream — broadcast and load-balanced delivery. - [Events Store (Persistent Pub/Sub)](/docs/integrations/faststream/how-to/events-store): Persistent pub/sub with replay — subscribe from any position in the stored event stream. - [Observability & Middleware](/docs/integrations/faststream/how-to/observability): Add metrics, tracing, and custom cross-cutting logic with FastStream middleware around KubeMQ messages. - [Queues (Point-to-Point)](/docs/integrations/faststream/how-to/queues): Reliable point-to-point queue messaging with ack/nack settlement, batching, TTL, delay, and dead-letter queues. - [Testing with TestKubeMQBroker](/docs/integrations/faststream/how-to/testing): Write fast unit tests against an in-memory broker — no live KubeMQ connection required. - Reference - [API Reference](/docs/integrations/faststream/reference/api): The kubemq-faststream public API — exported symbols, the pattern and ack enums, StartPosition, subscriber config, and the broker.request() RPC signature. - [Configuration Reference](/docs/integrations/faststream/reference/configuration): The kubemq-faststream connection surface — package facts, KubeMQBroker constructor options, URL formats, validation rules, and environment variables. - Scenarios - [Resilient Messaging Pipelines](/docs/integrations/faststream/scenarios/resilient-pipelines): Build production-grade workflows — saga, DLQ, circuit breaker, idempotency, and event sourcing — on KubeMQ FastStream. - [Web Framework Integration](/docs/integrations/faststream/scenarios/web-framework-integration): Run a KubeMQ FastStream broker alongside FastAPI, Django, Flask, or Starlette, sharing the async lifecycle. - Watermill - [Watermill](/docs/integrations/watermill): A production-ready Watermill pub/sub plugin for KubeMQ — Publisher/Subscriber across Events, EventsStore, and Queues, plus a native CQPublisher. - Concepts - [Watermill Concepts](/docs/integrations/watermill/concepts/concepts): How watermill-kubemq maps Watermill's Publisher/Subscriber/Router model onto KubeMQ patterns, marshaling, ack semantics, and streaming. - Tutorials - [Getting Started with Watermill](/docs/integrations/watermill/tutorials/getting-started): Install the plugin, start a KubeMQ broker, and run a first end-to-end Events publish/subscribe with the Watermill Router. - How-to guides - [Commands & Queries (Request-Reply)](/docs/integrations/watermill/how-to/commands-queries): Use the native CQPublisher for low-latency request-reply, or the Watermill requestreply component for middleware-compatible request-reply. - [Connection & Configuration](/docs/integrations/watermill/how-to/configuration): Configure the connection: address, ClientID, auth token, TLS, client reuse, custom marshaler, and health checks. - [Events](/docs/integrations/watermill/how-to/events): Publish and subscribe with the fire-and-forget Events pattern — fan-out, consumer groups, and streaming publish over the Watermill interfaces. - [Events Store](/docs/integrations/watermill/how-to/events-store): Use the persistent, replayable EventsStore pattern — durable storage, sequence numbers, six start options, and delivered metadata. - [Middleware & Observability](/docs/integrations/watermill/how-to/middleware-and-observability): Apply Watermill middleware, propagate OpenTelemetry traces, expose Prometheus metrics, and autoscale consumers with KEDA. - [Queues with Ack/Nack & DLQ](/docs/integrations/watermill/how-to/queues): Use the reliable Queues pattern with explicit acknowledgment, competing consumers, delayed and expiring messages, and dead-letter queues. - Reference - [API Reference](/docs/integrations/watermill/reference/api): Constructors and the public method surface of the watermill-kubemq Publisher, Subscriber, and CQPublisher types, plus repository Make targets. - [Configuration Reference](/docs/integrations/watermill/reference/configuration): Every PublisherConfig, SubscriberConfig, CQConfig, QueueMessagePolicy, and TLSConfig field, plus enums, validation rules, marshaling, and metadata keys. - Celery - [Celery](/docs/integrations/celery): Use KubeMQ as your Celery message broker and result backend with a one-line configuration change. - Concepts - [Celery Transport Concepts](/docs/integrations/celery/concepts): Understand how the KubeMQ Celery transport maps Celery semantics onto KubeMQ Queues and Events, plus the acknowledgment model and known limitations. - Tutorials - [Getting Started with Celery on KubeMQ](/docs/integrations/celery/tutorials/getting-started): Run a Celery app on KubeMQ in under 5 minutes — install, start a worker, dispatch a task, and enable the result backend. - How-to guides - [Canvas Workflows](/docs/integrations/celery/how-to/canvas-workflows): Compose Celery tasks into chains, groups, chords, and maps on KubeMQ, including the chord polling-fallback behavior. - [Configuration](/docs/integrations/celery/how-to/configuration): Complete reference for kubemq-celery broker URL schemes, transport options, TLS/mTLS, and async transport. - [Error Handling & Dead Letter Queues](/docs/integrations/celery/how-to/error-handling): Handle retries, dead letter queues, acks_late, idempotency, and Sentry monitoring with the KubeMQ Celery transport. - [Kubernetes Deployment & KEDA Autoscaling](/docs/integrations/celery/how-to/kubernetes): Deploy Celery workers and the KubeMQ broker on Kubernetes with health checks and KEDA queue-depth autoscaling. - [Migrating from Redis or RabbitMQ](/docs/integrations/celery/how-to/migration): Switch an existing Celery app from Redis or RabbitMQ to KubeMQ with one import and one broker URL change. - [Performance Tuning](/docs/integrations/celery/how-to/performance): Tune kubemq-celery worker concurrency, prefetch, batch receive, and gRPC keepalive — with ready-made workload profiles for API, batch, and mixed traffic. - [Result Backend](/docs/integrations/celery/how-to/result-backend): Enable the KubeMQ queue-peek result backend to store and retrieve Celery task results without external Redis or a database. - [Scheduling & Delayed Delivery](/docs/integrations/celery/how-to/scheduling): Schedule Celery tasks with countdown, ETA, and Celery Beat on KubeMQ using native server-side delay_in_seconds. - [Troubleshooting & FAQ](/docs/integrations/celery/how-to/troubleshooting): Diagnose and fix common kubemq-celery issues — connection failures, tasks not executing, duplicate runs, missing results, and monitoring gaps. - Reference - [Configuration Reference](/docs/integrations/celery/reference/configuration): Reference for kubemq-celery — broker URL schemes, public API, Celery settings, environment variables, monitoring commands, and exceptions. - [Transport Options](/docs/integrations/celery/reference/transport-options): Reference for every kubemq-celery broker_transport_options and result_backend_transport_options key — type, default, and behavior. - Scenarios - [FastAPI Task Dispatch with KEDA Autoscaling](/docs/integrations/celery/scenarios/fastapi-tasks-kubernetes): Build a FastAPI service that dispatches Celery tasks to KubeMQ-backed workers on Kubernetes, autoscaled by queue depth with KEDA. - Ray Serve - [Ray Serve](/docs/integrations/rayserve): Run queue-based async and sync ML inference on Ray Serve with KubeMQ as the broker, result backend, autoscaler, and progress bus. - Concepts - [Concepts](/docs/integrations/rayserve/concepts): How the adapter maps Ray Serve's TaskProcessorAdapter onto KubeMQ Queues, Queries, and Events. - Tutorials - [Getting Started with Ray Serve](/docs/integrations/rayserve/tutorials/getting-started): Install the adapter, start a broker, and run your first end-to-end async inference task in minutes. - How-to guides - [Async Inference](/docs/integrations/rayserve/how-to/async-inference): Enqueue inference tasks onto a KubeMQ Queue and poll for results — the core asynchronous model. - [Autoscaling](/docs/integrations/rayserve/how-to/autoscaling): Scale Ray Serve replicas on KubeMQ queue depth using the built-in policy or KEDA. - [Cancellation](/docs/integrations/rayserve/how-to/cancellation): Soft-cancel an in-flight inference task with cancel_task_sync — overwrite its result with a CANCELLED status. - [Configuration](/docs/integrations/rayserve/how-to/configuration): Every KubeMQAdapterConfig field and how to tune the adapter for your workload. - [Connection & Security](/docs/integrations/rayserve/how-to/connection-security): Connect to KubeMQ with custom addresses, JWT auth, TLS, and mutual TLS. - [Retries & Dead Letter Queues](/docs/integrations/rayserve/how-to/dlq-and-retries): Configure retry limits, route failures to a DLQ, and alert on permanent failures with the on_dlq callback. - [Metrics](/docs/integrations/rayserve/how-to/metrics): Collect the adapter's 8-metric dict — queue depth, in-flight, DLQ depth, counters, and duration stats — for dashboards and alerting. - [Progress Tracking](/docs/integrations/rayserve/how-to/progress-tracking): Emit and observe real-time task progress events over KubeMQ Events during long-running inference. - [Sync Inference](/docs/integrations/rayserve/how-to/sync-inference): Get blocking request-response inference over KubeMQ Queries with query_task_sync — no polling required. - Reference - [API Reference](/docs/integrations/rayserve/reference/api): The kubemq-rayserve package surface — adapter methods, extension methods, the autoscaling policy, metrics, and TaskResult statuses. - [Configuration Reference](/docs/integrations/rayserve/reference/configuration): Every KubeMQAdapterConfig field, validation rules, dependencies, and the broker requirement for kubemq-rayserve. - Scenarios - [GPU Multi-Model Inference Service](/docs/integrations/rayserve/scenarios/gpu-multi-model-service): Serve multiple GPU-backed models behind separate KubeMQ queues with batching, progress, and DLQ alerting. - [Kubernetes Production Deployment](/docs/integrations/rayserve/scenarios/kubernetes-production-deployment): Deploy the adapter, a KubeMQ broker, and a Ray cluster to Kubernetes with KEDA autoscaling and secure config. - .NET Aspire - [.NET Aspire](/docs/integrations/aspire): Provision KubeMQ and configure IKubeMQClient in .NET Aspire apps with health checks, OpenTelemetry, and keyed DI. - Concepts - [Concepts](/docs/integrations/aspire/concepts): The two-package model, container provisioning, connection-string injection, keyed DI, and the health-check and OpenTelemetry wiring in Aspire. - Tutorials - [Getting Started with .NET Aspire](/docs/integrations/aspire/tutorials/getting-started): Provision KubeMQ in an Aspire AppHost and send your first message from a service project in minutes. - How-to guides - [Commands and Queries (RPC)](/docs/integrations/aspire/how-to/commands-queries): Implement synchronous request-response messaging with KubeMQ commands and queries through the Aspire client. - [Client Configuration and TLS](/docs/integrations/aspire/how-to/configuration-and-tls): Configure the KubeMQ client through appsettings.json or delegates, including TLS, gRPC tuning, keepalive, and reconnect. - [Pub/Sub and Events Store](/docs/integrations/aspire/how-to/events): Publish and subscribe to KubeMQ events through the Aspire-injected IKubeMQClient, including persistent events store replay. - [Health Checks and OpenTelemetry](/docs/integrations/aspire/how-to/health-checks-observability): Understand the readiness/liveness health checks and OpenTelemetry tracing and metrics the client registers by default. - [Multiple KubeMQ Instances (Keyed DI)](/docs/integrations/aspire/how-to/keyed-multi-instance): Register and inject multiple keyed KubeMQ clients in a single Aspire service. - [Queues](/docs/integrations/aspire/how-to/queues): Send, receive, acknowledge, and reject durable queue messages with the Aspire-injected IKubeMQClient. - Reference - [Client API](/docs/integrations/aspire/reference/client-api): AddKubeMQClient and AddKeyedKubeMQClient registration methods, plus the health checks and OpenTelemetry sources the client wires by default. - [Configuration](/docs/integrations/aspire/reference/configuration): The KubeMQClientSettings table, configuration sections, connection-string rules, and version requirements for the KubeMQ .NET Aspire client. - [Hosting API](/docs/integrations/aspire/reference/hosting-api): AddKubeMQ and the WithLicenseKey, WithDataVolume, and WithImageTag builder methods for provisioning a KubeMQ container in the Aspire AppHost. - KEDA - [KEDA](/docs/integrations/keda): Autoscale KubeMQ queue consumers on Kubernetes with the KubeMQ KEDA external scaler, driven by live queue depth — including scale-to-zero. - Concepts - [Concepts](/docs/integrations/keda/concepts): How the KubeMQ KEDA external scaler works — the external-scaler gRPC protocol, the Waiting metric, and external vs external-push trigger types. - Tutorials - [Getting Started with KEDA Autoscaling](/docs/integrations/keda/tutorials/getting-started): Install the KubeMQ KEDA scaler with Helm and autoscale your first queue consumer on queue depth in minutes. - How-to guides - [Autoscale a Queue Consumer](/docs/integrations/keda/how-to/autoscale-queue-consumer): Configure a KEDA ScaledObject to scale a KubeMQ queue consumer Deployment up and down based on the Waiting message count. - [Scale to Zero with Push Mode](/docs/integrations/keda/how-to/scale-to-zero): Use the external-push trigger to scale a KubeMQ queue consumer from zero replicas and back, with fast scale-from-zero detection. - [Secure the KubeMQ Connection with TLS and Auth](/docs/integrations/keda/how-to/tls-and-auth): Connect the KEDA scaler to a TLS-secured, authenticated KubeMQ broker using a CA certificate and a TriggerAuthentication token. - Reference - [Environment Variables](/docs/integrations/keda/reference/environment-variables): The two environment variables the KubeMQ KEDA scaler reads at startup, plus its installation methods and how to run a local KubeMQ broker. - [Error Codes](/docs/integrations/keda/reference/error-codes): How the KubeMQ KEDA scaler maps KubeMQ errors to gRPC status codes so KEDA can apply its fallback replica strategy. - [gRPC RPCs](/docs/integrations/keda/reference/grpc-rpcs): The KubeMQ KEDA scaler's ExternalScaler gRPC surface — the four RPCs, the single metric, retry behavior, and gRPC health checks. - [ScaledObject Metadata](/docs/integrations/keda/reference/scaled-object-metadata): Complete KEDA ScaledObject trigger metadata, scaler Service address, trigger types, Helm values, and example manifests for the KubeMQ KEDA scaler.