Gabriele Santomaggio

- publish rate - consumer rate - etc...

Per conversation during the retro. To increase the quorum queues users we could change our https://www.rabbitmq.com/getstarted.html examples. Use quorum queues instead of classic queues.

Per conversation with @acogoluegnes Add some Stream examples with AMQP clients and Native clients. We can start with Java/Net.

Error during close consumer during the delivery

1

Bug found by @ricsiLT When `consumer.close()` raises an exception when there are still some deliver frames on the network. Also, the client receives `throw new ArgumentException($"Unknown or unexpected tag: {tag}",...

Work in progress Single Active Consumer

2

Work on this feature with @Zerpet Signed-off-by: Gabriele Santomaggio Closes https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/issues/146 Note: `SacTests` will fail until the 3.11 is released

Add Compression Codecs for sub-entry

6

By default client Support `None` and `GZIP`. We need to provide the examples for: ```csharp Snappy = 2, Lz4 = 3, Zstd = 4, ``` as external codec to be...

Ref https://github.com/rabbitmq/rabbitmq-server/pull/5321 Per [internal conversion](https://vmware.slack.com/archives/C039S4USVPG/p1659086921580689)

Implement the Single-Active Consumer feature. Java reference: https://rabbitmq.github.io/rabbitmq-stream-java-client/sac/htmlsingle/#single-active-consumer Single Active Consumer requires RabbitMQ 3.11 or more.

In the next RabbitMQ [version will be possible](https://github.com/rabbitmq/rabbitmq-server/pull/5131) to change the frame_size for the stream. The client can ask to change the frame_size, but it can't be bigger than the...

Implement single active consumer for streams" (3.11 feature)