This library is in early stages of development. It is meant to be used with RabbitMQ 4.0.
- start the broker with
ci/start-broker.sh
- run the tests with
dotnet test ./Build.csproj --logger "console;verbosity=detailed" /p:AltCover=true
You can find an example in: docs/Examples/GettingStarted
- Declare queues
- Declare exchanges
- Declare bindings
- Simple Publish messages
- Implement backpressure ( atm it is implemented with MaxInflightMessages
MaxInFlight(2000).
) - Simple Consume messages
- Implement metrics ( See
System.Diagnostics.DiagnosticSource
Link ) - Recovery connection on connection lost
- Recovery management on connection lost
- Recovery queues on connection lost
- Recovery publisher on connection lost
- Recovery consumer on connection lost
- Docker image to test in LRE
- Check the TODO in the code