How to make messages persistent? #11
Comments
|
Seems if I add the field DeliveryMode to MessageProperties and to the list of fields in unmarshal/marshal I'm able to get persistency. I don't have enough of an overview to know what else must be added to avoid breaking something, though. |
|
Turns out I had misunderstood the documentation/code, and that to make messages persistent I had to set MessageHeader.Durable to 'true'! |
mihaitodor
added a commit
to redpanda-data/connect
that referenced
this issue
Apr 15, 2024
The `amqp_0_9` has this field already: https://www.benthos.dev/docs/components/outputs/amqp_0_9/#persistent Implementation inspired from here: Azure/go-amqp#11 This omission was reported on Slack: https://gophers.slack.com/archives/CLWCBK7FY/p1713189832118529 Signed-off-by: Mihai Todor <todormihai@gmail.com>
1 task
mihaitodor
added a commit
to redpanda-data/connect
that referenced
this issue
Apr 15, 2024
The `amqp_0_9` has this field already: https://www.benthos.dev/docs/components/outputs/amqp_0_9/#persistent Implementation inspired from here: Azure/go-amqp#11 This omission was reported on Slack: https://gophers.slack.com/archives/CLWCBK7FY/p1713189832118529 Signed-off-by: Mihai Todor <todormihai@gmail.com>
mihaitodor
added a commit
to redpanda-data/connect
that referenced
this issue
Apr 15, 2024
The `amqp_0_9` has this field already: https://www.benthos.dev/docs/components/outputs/amqp_0_9/#persistent Implementation inspired from here: Azure/go-amqp#11 This omission was reported on Slack: https://gophers.slack.com/archives/CLWCBK7FY/p1713189832118529 Signed-off-by: Mihai Todor <todormihai@gmail.com>
mihaitodor
added a commit
to redpanda-data/connect
that referenced
this issue
Apr 15, 2024
The `amqp_0_9` has this field already: https://www.benthos.dev/docs/components/outputs/amqp_0_9/#persistent Implementation inspired from here: Azure/go-amqp#11 This omission was reported on Slack: https://gophers.slack.com/archives/CLWCBK7FY/p1713189832118529 Signed-off-by: Mihai Todor <todormihai@gmail.com>
mihaitodor
added a commit
to redpanda-data/connect
that referenced
this issue
Apr 16, 2024
The `amqp_0_9` has this field already: https://www.benthos.dev/docs/components/outputs/amqp_0_9/#persistent Implementation inspired from here: Azure/go-amqp#11 This omission was reported on Slack: https://gophers.slack.com/archives/CLWCBK7FY/p1713189832118529 Signed-off-by: Mihai Todor <todormihai@gmail.com>
wehr503
pushed a commit
to uniserv-org/redpanda-data-connect
that referenced
this issue
Apr 19, 2024
The `amqp_0_9` has this field already: https://www.benthos.dev/docs/components/outputs/amqp_0_9/#persistent Implementation inspired from here: Azure/go-amqp#11 This omission was reported on Slack: https://gophers.slack.com/archives/CLWCBK7FY/p1713189832118529 Signed-off-by: Mihai Todor <todormihai@gmail.com> Signed-off-by: Stephan Wehr <stephan.wehr@uniserv.com>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Hi! I might have overlooked something, but I'm unable to make new queues/messages persistent. I'm coming from Java where I've been able to create new queues/messages that default to persistent. I've found the 'durability configuration' link option on create sender/receiver, but that does not seem to make messages persistent.
How do I mark my messages as persistent?
Thanks in advance!
The text was updated successfully, but these errors were encountered: