Skip to content

Commit c905d41

Browse files
authored
Merge branch 'v1.12' into issue_3567
2 parents f3805f6 + 87ee428 commit c905d41

File tree

1 file changed

+24
-0
lines changed

1 file changed

+24
-0
lines changed

daprdocs/content/en/reference/components-reference/supported-pubsub/setup-rabbitmq.md

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,10 @@ spec:
6262
value: false
6363
- name: ttlInSeconds
6464
value: 60
65+
- name: clientName
66+
value: {podName}
67+
- name: heartBeat
68+
value: 10s
6569
```
6670
6771
{{% alert title="Warning" color="warning" %}}
@@ -96,6 +100,8 @@ The above example uses secrets as plain strings. It is recommended to use a secr
96100
| caCert | Required for using TLS | Certificate Authority (CA) certificate in PEM format for verifying server TLS certificates. | `"-----BEGIN CERTIFICATE-----\n<base64-encoded DER>\n-----END CERTIFICATE-----"`
97101
| clientCert | Required for using TLS | TLS client certificate in PEM format. Must be used with `clientKey`. | `"-----BEGIN CERTIFICATE-----\n<base64-encoded DER>\n-----END CERTIFICATE-----"`
98102
| clientKey | Required for using TLS | TLS client key in PEM format. Must be used with `clientCert`. Can be `secretKeyRef` to use a secret reference. | `"-----BEGIN RSA PRIVATE KEY-----\n<base64-encoded PKCS8>\n-----END RSA PRIVATE KEY-----"`
103+
| clientName | N | This RabbitMQ [client-provided connection name](https://www.rabbitmq.com/connections.html#client-provided-names) is a custom identifier. If set, the identifier is mentioned in RabbitMQ server log entries and management UI. Can be set to {uuid}, {podName}, or {appID}, which is replaced by Dapr runtime to the real value. | `"app1"`, `{uuid}`, `{podName}`, `{appID}`
104+
| heartBeat | N | Defines the heartbeat interval with the server, detecting the aliveness of the peer TCP connection with the RabbitMQ server. Defaults to `10s` . | `"10s"`
99105

100106

101107
## Communication using TLS
@@ -412,6 +418,24 @@ client.PublishEvent(ctx, PUBSUB_NAME, TOPIC_NAME, []byte(strconv.Itoa(orderId)),
412418

413419
{{< /tabs >}}
414420

421+
## Use quorum queues
422+
423+
By default, Dapr creates `classic` queues. To create `quorum` queues, add the following metadata to your pub/sub [subscription]({{< ref subscription-schema.md >}})
424+
425+
```yaml
426+
apiVersion: dapr.io/v2alpha1
427+
kind: Subscription
428+
metadata:
429+
name: pubsub
430+
spec:
431+
topic: checkout
432+
routes:
433+
default: /orders
434+
pubsubname: order-pub-sub
435+
metadata:
436+
queueType: quorum
437+
```
438+
415439
## Time-to-live
416440
417441
You can set a time-to-live (TTL) value at either the message or component level. Set default component-level TTL using the component spec `ttlInSeconds` field in your component.

0 commit comments

Comments
 (0)