rabbitmq-stream-dotnet-client

rabbitmq-stream-dotnet-client copied to clipboard

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.

Gsantomaggio

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...

Gsantomaggio

Implement single active consumer for streams" (3.11 feature)

Gsantomaggio

Targeting .NET Standard 2.0 or .NET Standard 2.1

2

Would it be possible also to target [.NET Standard 2.0](https://docs.microsoft.com/en-us/dotnet/standard/net-standard?tabs=net-standard-2-0#select-net-standard-version) similar to [RabbitMQ.Client](https://github.com/rabbitmq/rabbitmq-dotnet-client/blob/main/projects/RabbitMQ.Client/RabbitMQ.Client.csproj#L4)? This would provide compatibility for older applications and help where teams are still needing to support more...

jdaltonchilders

Review the documentation. Per conversation with @pstack2021

Gsantomaggio

Evaluate use of Wait vs await

2

Also, use of `CancellationToken` for long-running tasks. See this discussion: https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/pull/104/files#r854652659

lukebakken

Add Documentation and examples

1

Add some basic documentation and examples

Gsantomaggio

Implement ThrowIfDisposed() on disposed object. Minor improvement

Gsantomaggio

Customize the SystemStream behaviour and pass parameters as: - batchsize - socket.NoDelay - socket.SendBufferSize - socket.ReceiveBufferSize

Gsantomaggio

Implement CRC control

6

Implement `CRC32` check before creating [the Chunk](https://github.com/rabbitmq/rabbitmq-stream-dotnet-client/blob/main/RabbitMQ.Stream.Client/Deliver.cs#L118) I can't find a standard library. A lot of people use https://github.com/damieng/DamienGKit Any thought?

Gsantomaggio