From 3d4e97d4fdbe9501e01840711576cd6f699084a6 Mon Sep 17 00:00:00 2001 From: Dmitry Shmulevich Date: Tue, 28 Dec 2021 16:06:29 -0800 Subject: [PATCH] updated RabbitMQ Pub/Sub status Signed-off-by: Dmitry Shmulevich --- .../supported-pubsub/_index.md | 2 +- .../supported-pubsub/setup-rabbitmq.md | 29 ++++++++++--------- 2 files changed, 17 insertions(+), 14 deletions(-) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/_index.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/_index.md index dea6d87a3..6b452ba13 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/_index.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/_index.md @@ -29,7 +29,7 @@ Table captions: | [In Memory]({{< ref setup-inmemory.md >}}) | Alpha | v1 | 1.4 | | [JetStream]({{< ref setup-jetstream.md >}}) | Alpha | v1 | 1.4 | | [Pulsar]({{< ref setup-pulsar.md >}}) | Alpha | v1 | 1.0 | -| [RabbitMQ]({{< ref setup-rabbitmq.md >}}) | Alpha | v1 | 1.0 | +| [RabbitMQ]({{< ref setup-rabbitmq.md >}}) | Stable | v1 | 1.6 | | [Redis Streams]({{< ref setup-redis-pubsub.md >}}) | Stable | v1 | 1.0 | ### Amazon Web Services (AWS) diff --git a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md index ad0c1c040..17b2bcadb 100644 --- a/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md +++ b/daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md @@ -21,34 +21,36 @@ spec: metadata: - name: host value: "amqp://localhost:5672" + - name: consumerID + value: myapp - name: durable - value: "false" + value: false - name: deletedWhenUnused - value: "false" + value: false - name: autoAck - value: "false" + value: false - name: deliveryMode - value: "0" + value: 0 - name: requeueInFailure - value: "false" + value: false - name: prefetchCount - value: "0" + value: 0 - name: reconnectWait - value: "0" + value: 0 - name: concurrencyMode value: parallel - name: backOffPolicy - value: "exponential" + value: exponential - name: backOffInitialInterval - value: "100" + value: 100 - name: backOffMaxRetries - value: "16" + value: 16 - name: enableDeadLetter # Optional enable dead Letter or not - value: "true" + value: true - name: maxLen # Optional max message count in a queue - value: "3000" + value: 3000 - name: maxLenBytes # Optional maximum length in bytes of a queue. - value: "10485760" + value: 10485760 ``` {{% alert title="Warning" color="warning" %}} The above example uses secrets as plain strings. It is recommended to use a secret store for the secrets as described [here]({{< ref component-secrets.md >}}). @@ -59,6 +61,7 @@ The above example uses secrets as plain strings. It is recommended to use a secr | Field | Required | Details | Example | |--------------------|:--------:|---------|---------| | host | Y | Connection-string for the rabbitmq host | `amqp://user:pass@localhost:5672` +| consumerID | N | Consumer ID a.k.a consumer tag organizes one or more consumers into a group. Consumers with the same consumer ID work as one visrtual consumer, i.e. a message is processed only once by one of the consumers in the group. If the consumer ID is not set, dapr runtime will set it to the dapr application ID | | durable | N | Whether or not to use [durable](https://www.rabbitmq.com/queues.html#durability) queues. Defaults to `"false"` | `"true"`, `"false"` | deletedWhenUnused | N | Whether or not the queue should be configured to [auto-delete](https://www.rabbitmq.com/queues.html) Defaults to `"true"` | `"true"`, `"false"` | autoAck | N | Whether or not the queue consumer should [auto-ack](https://www.rabbitmq.com/confirms.html) messages. Defaults to `"false"` | `"true"`, `"false"`