RabbitMQ Stream protocol support

[trialize]

Are there any plans to support Streams?

https://www.rabbitmq.com/streams.html

[h0jeZvgoxFepBQ2C]

Yeah, please support Streams!!!1! ❤️

[carlhoerberg]

It's already supported, just set the queue argument x-queue-type to stream, and when you consume you can set the argument x-stream-offset to a value specified in the link above.

[h0jeZvgoxFepBQ2C]

Oh ok cool! Was scanning through the documentation, but couldn't find any mention of the streaming feature.
Would be nice to add this to the documentation!

Thanks for the answer! ❤️

[h0jeZvgoxFepBQ2C]

@carlhoerberg do you know if there is any javascript wevbrowser-library which supports streams? I know this is not related to the bunny gem, but just asking :)

[carlhoerberg]

Yes https://github.com/cloudamqp/amqp-client.js#websockets

[h0jeZvgoxFepBQ2C]

Thank you so much!

[michaelklishin]

There are no plans to support the stream protocol in Bunny. Our team follows the "one protocol, one client" philosophy. RabbitMQ Streams clients in Java, Go, Python are all separate from their AMQP 0-9-1 or AMQP 1.0 clients.

You can, however, use streams from Bunny today over AMQP 0-9-1 as if it was a queue.

I don't have any immediate plans to work on a Ruby client for RabbitMQ Streams. This is open source software, you are welcome to scratch your own itch and develop one. The stream protocol is documented in quite a bit of detail.

[h0jeZvgoxFepBQ2C]

Hm, I'm not sure if I understand you correctly.

Is there a difference between a (potential) ruby client for rabbitmq streams and bunny (since you can use bunny already with streams by setting mentioned headers above)?

So I don't understand what is missing, since you can use already the bunny gem for streams?

[michaelklishin]

I believe this is answered in RabbitMQ's stream protocol documentation. You can use streams from Bunny as if they were queues. But they are not, they provide a different set of operations which may be highly desirable for some applications. For that, you need a Ruby client for the RabbitMQ Stream protocol.

[h0jeZvgoxFepBQ2C]

Ah ok I see, thank you!