From bb60da2a6bb5e20b818f5450429c837a2549835e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro=20Aguilar?= Date: Mon, 28 Aug 2023 08:21:52 +0200 Subject: [PATCH 1/3] Create 'quorum' queues in RabbitMQ MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Álvaro Aguilar --- .../supported-pubsub/setup-rabbitmq.md | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) 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 8d006a35aff..83a6a3a0561 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 @@ -409,6 +409,24 @@ client.PublishEvent(ctx, PUBSUB_NAME, TOPIC_NAME, []byte(strconv.Itoa(orderId)), {{< /tabs >}} +## Use quorum queues + +By default Dapr creates 'classic' queues. To create 'quorum' queues: + +```yaml +apiVersion: dapr.io/v2alpha1 +kind: Subscription +metadata: + name: pubsub +spec: + topic: checkout + routes: + default: /orders + pubsubname: order-pub-sub + metadata: + queueType: quorum +``` + ## Related links - [Basic schema for a Dapr component]({{< ref component-schema >}}) in the Related links section From f149359b1b4d405e26b90d25639e9c608f245dae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro=20Aguilar-Tablada=20Espinosa?= Date: Fri, 1 Sep 2023 11:08:03 +0200 Subject: [PATCH 2/3] Update daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Hannah Hunter <94493363+hhunter-ms@users.noreply.github.com> Signed-off-by: Álvaro Aguilar-Tablada Espinosa --- .../components-reference/supported-pubsub/setup-rabbitmq.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 83a6a3a0561..ee1882b65dd 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 @@ -411,7 +411,7 @@ client.PublishEvent(ctx, PUBSUB_NAME, TOPIC_NAME, []byte(strconv.Itoa(orderId)), ## Use quorum queues -By default Dapr creates 'classic' queues. To create 'quorum' queues: +By default, Dapr creates `classic` queues. To create `quorum` queues, add the following metadata to your subscription: ```yaml apiVersion: dapr.io/v2alpha1 From f47b341409c98461765ffa008a2beb35a070ca66 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=81lvaro=20Aguilar-Tablada=20Espinosa?= Date: Mon, 18 Sep 2023 08:47:07 +0200 Subject: [PATCH 3/3] Update daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Mark Fussell Signed-off-by: Álvaro Aguilar-Tablada Espinosa --- .../components-reference/supported-pubsub/setup-rabbitmq.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 34c06629fdb..c966f69885a 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 @@ -414,7 +414,7 @@ client.PublishEvent(ctx, PUBSUB_NAME, TOPIC_NAME, []byte(strconv.Itoa(orderId)), ## Use quorum queues -By default, Dapr creates `classic` queues. To create `quorum` queues, add the following metadata to your subscription: +By default, Dapr creates `classic` queues. To create `quorum` queues, add the following metadata to your pub/sub [subscription]({{< ref subscription-schema.md >}}) ```yaml apiVersion: dapr.io/v2alpha1