New RabbitMQ Streams Feature about rabbitmq-mock HOT 1 OPEN

Fork with branch

As a follow up, I forked the project and I have a branch that has started the implementation of this new feature. It is a very naive implementation that reuses a lot of the existing code. My intention is that the feature behaves like the tests should describe (in code) but I am missing quite a few.

• stream acts as a fanout for all consumers
• all consumers of a stream can start reading at any offset till the end

The branch is here: https://github.com/hanzo2001/rabbitmq-mock/tree/feature/naive-streams-implementation

Do I need to PR for a checkup? (my stuff is not PR ready yet)

TODO

I have not tested the expected errors (no qos, etc). I have no clue as to what is supposed to happen with other Channel calls like basicNack, basicReject, etc in the context of Streams. I only understand them as read and continue (only Ack and continue to the next). Streams do not have a DLQ concept of undeliverable, the messages are not consumed and will exist forever or until the retention policy allows it. In addition, I think there is no concept of requeue.

from rabbitmq-mock.