Configuration

The RabbitMQ (AMQP 0-9-1) connector is configured server-side under the Connectors.Amqp block of the KubeMQ server config, exposed as twelve CONNECTORS_AMQP_* environment variables. The connector is opt-in (disabled by default) — you must explicitly enable it. It ships with sensible production defaults, so once enabled no other env var is required.

Enable / disable

Enable the connector with its enable variable:

docker run -d \  --name kubemq \  -p 5672:5672 \  -p 5671:5671 \  -p 50000:50000 \  -e KUBEMQ_TOKEN=YOUR_LICENSE_KEY \  -e CONNECTORS_AMQP_ENABLE=true \  europe-docker.pkg.dev/kubemq/images/kubemq:next

To turn it off again:

docker run -d -p 50000:50000 -e KUBEMQ_TOKEN=YOUR_LICENSE_KEY -e CONNECTORS_AMQP_ENABLE=false europe-docker.pkg.dev/kubemq/images/kubemq:next

Field notes

• Port / TlsPort — when Enable=true, at least one of Port or TlsPort must be non-zero, otherwise the server reports bad AMQP configuration: Enable=true requires Port or TlsPort. The plain listener is amqp://host:5672/; the TLS listener is amqps://host:5671/.
• MaxConnections — 0 means unlimited; over-limit connections are accepted then closed with code 320.
• DefaultVhost — the segment AMQP vhost / maps to. The default literal is "default" (a reserved vhost), not /. The channel mapping is amqp.{vhost}.{queue}. Reach the default vhost by connecting to /; connecting directly to a vhost literally named default is rejected. See the reserved-vhost callout in the configuration reference.
• GetBatchSize — bounds per-basic.get pulls (default 32).
• DeadLetterMaxHops — the dead-letter cycle cap per (queue, reason); default 16.
• MaxReceiveCount — the poison-message receive cap; 0 inherits the broker default.

TLS

TLS has no AMQP-specific configuration. TLS/AMQPS on port 5671 is managed by the server-global Security block, shared with gRPC and REST. The TLS listener is active only when that block is configured (Mode ≠ None); TLS 1.2+ is enforced and mTLS is supported. Connecting over TLS is purely a transport swap (KUBEMQ_AMQP_URL=amqps://host:5671/); the AMQP frames on top are identical. See TLS and mTLS and Auth & security.

Configuring the connector

The same settings can be supplied through a TOML config file, environment variables, or docker run flags. Each environment variable uses the CONNECTORS_AMQP_ prefix.

[Connectors.Amqp]
  Enable = true
  Port = 5672
  TlsPort = 5671
  HeartbeatSeconds = 60
  FrameMax = 131072
  ChannelMax = 2047
  MaxConnections = 1000
  MaxBodySize = 104857600
  DefaultVhost = "default"
  GetBatchSize = 32
  DeadLetterMaxHops = 16
  MaxReceiveCount = 0

CONNECTORS_AMQP_ENABLE=true
CONNECTORS_AMQP_PORT=5672
CONNECTORS_AMQP_TLS_PORT=5671
CONNECTORS_AMQP_HEARTBEAT_SECONDS=60
CONNECTORS_AMQP_FRAME_MAX=131072
CONNECTORS_AMQP_CHANNEL_MAX=2047
CONNECTORS_AMQP_MAX_CONNECTIONS=1000
CONNECTORS_AMQP_MAX_BODY_SIZE=104857600
CONNECTORS_AMQP_DEFAULT_VHOST=default
CONNECTORS_AMQP_GET_BATCH_SIZE=32
CONNECTORS_AMQP_DEAD_LETTER_MAX_HOPS=16
CONNECTORS_AMQP_MAX_RECEIVE_COUNT=0

docker run -d \  --name kubemq \  -p 5672:5672 \  -p 5671:5671 \  -p 50000:50000 \  -e KUBEMQ_TOKEN=YOUR_LICENSE_KEY \  -e CONNECTORS_AMQP_ENABLE=true \  -e CONNECTORS_AMQP_MAX_CONNECTIONS=5000 \  -e CONNECTORS_AMQP_FRAME_MAX=262144 \  europe-docker.pkg.dev/kubemq/images/kubemq:next

Related