Message headers in the stream protocol

94 views
Skip to first unread message

Mc Polu

unread,
Mar 28, 2023, 5:14:52 PM3/28/23
to rabbitmq-users
Hello,

Thank you very much for making RabbitMQ open source and for supporting it, it is a fantastic product.

I have producers and consumers communicating via topic exchange using AMQP 0.9.1. The messages carry some metadata in the headers, for example timestamp in milliseconds from the plugin. I have created a stream queue and bound it to the topic exchange with a certain routing key. This works very well.

When I consume from a stream queue using a AMQP client, I can see data in the headers, same as if I subscribed to a topic the traditional way. However when I consume from a stream queue using the stream protocol, I cannot find a way to retrieve the headers.

Is there a way to retrieve message headers while using the stream protocol, please?

Thank you.

Arnaud Cogoluègnes

unread,
Mar 29, 2023, 3:02:45 AM3/29/23
to rabbitmq-users
AMQP 0.9.1 headers should be translated to AMQP 1.0 application properties (streams use AMQP 1.0 message format to encode messages). How to access those depends on the stream client library you are using.

Could you provide a standalone program to help us figure out what is going on? Versions of the software (broker and client libraries) are welcome as well.

Thanks.

Arnaud Cogoluègnes

unread,
Mar 29, 2023, 7:13:59 AM3/29/23
to rabbitmq-users
Thanks for reporting back, I'm glad it's working as expected. Please use the mailing list email address next time, this way everyone can benefit from your feedback.

> On Wed, Mar 29, 2023 at 11:53 AM Conner McPolu wrote:
> Thank you, you are correct headers make their way to ApplicationProperties. I just didn't know to look there. Thank you very much for the help! I am using the C# stream client v1.2.0

Conner McPolu

unread,
Mar 29, 2023, 11:21:36 AM3/29/23
to Arnaud Cogoluègnes, rabbitmq-users
Thank you, you are correct headers make their way to ApplicationProperties. I just didn't know to look there. Thank you very much for the help! I am using the C# stream client v1.2.0


Reply all
Reply to author
Forward
0 new messages