Skip to content

Commit accc567

Browse files
authored
Merge branch 'v1.16' into feat-baggage-new
2 parents 4d4c31e + e194a2a commit accc567

File tree

2 files changed

+9
-1
lines changed

2 files changed

+9
-1
lines changed

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,7 @@ The above example uses secrets as plain strings. It is recommended to use a [sec
9595
| subscribeMode | N | Subscription mode indicates the cursor persistence, durable subscription retains messages and persists the current position. Default: `"durable"` | `"durable"`, `"non_durable"` |
9696
| partitionKey | N | Sets the key of the message for routing policy. Default: `""` | |
9797
| `maxConcurrentHandlers` | N | Defines the maximum number of concurrent message handlers. Default: `100` | `10`
98+
| replicateSubscriptionState | N | Enable replication of subscription state across geo-replicated Pulsar clusters. Default: `"false"` | `"true"`, `"false"` |
9899

99100
### Authenticate using Token
100101

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

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,8 @@ spec:
6666
value: {podName}
6767
- name: heartBeat
6868
value: 10s
69+
- name: publishMessagePropertiesToMetadata
70+
value: "true"
6971
```
7072
7173
{{% alert title="Warning" color="warning" %}}
@@ -102,7 +104,7 @@ The above example uses secrets as plain strings. It is recommended to use a secr
102104
| 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-----"`
103105
| 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}`
104106
| 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"`
105-
107+
| `publishMessagePropertiesToMetadata` | N | Whether to publish AMQP message properties (headers, message ID, etc.) to the metadata. | "true", "false"
106108

107109
## Communication using TLS
108110

@@ -475,6 +477,11 @@ spec:
475477
singleActiveConsumer: "true"
476478
```
477479

480+
## Publishing message properties to metadata
481+
482+
To enable [message properties](https://www.rabbitmq.com/docs/publishers#message-properties) being published in the metadata, set the `publishMessagePropertiesToMetadata` field to `"true"` in the component spec.
483+
This will include properties such as message ID, timestamp, and headers in the metadata of the published message.
484+
478485
## Related links
479486

480487
- [Basic schema for a Dapr component]({{% ref component-schema %}}) in the Related links section

0 commit comments

Comments
 (0)