RabbitMQ.Dataflows library helps use RabbitMQ as well as create powerful RabbitMQ powered workflows.
$ dotnet add package HouseofCat.EncryptionA RabbitMQ library of .NET tools to help rapidly develop well performant services or
to just help manage durable connectivity with the RabbitMQ.Client!
Dataflows have configurable concurrency, serialization, monitoring, compression, and
encryption all as first class citizens. This paradigm allows developers to just focus on
the important stuff - getting work done
Here are some features ready with RabbitMQ and Dataflows today!
namespace HouseofCat.RabbitMQ.Pools;.ILogger<T> via LogHelpers.IWorkState simplifies functional generic returns and integration.Json (System.Text.Json and Newtonsoft) and MessagePack serialization providers.ISerializationProvider and have basic
implementations.IEncryptionProvider and have basic
implementations.ICompressionProvider and have basic
implementations.WorkState.IsFaulted flag.The benefits of a dataflow pattern extend beyond fancy machine learning and Tensorflows or high throughput GCP Dataflow for mass computation. When brought to the service level, it helps organize your code into more manageable blocks. You can still write monolithic functions, but you would be hamstringing yourself and scarificing concurrency and parallelism. By designing code into small functional steps, you always write better, cleaner, code reduced with cyclomatic complexity. That very same code is easier to UnitTest. The orchestration of the function calls are the order they are added allowing you extend the original functionality infinitely. You don't have to write deserialization or post-processing encryption/compression as they all baked in. Designing from the ground up with concurrency and parallelism, you stay nimble and fast - able to scale up internally, before horizontally and vertically, saving costs. All without needing code changed or refactored.
Lastly, after everything is said and done, all your business code is re-usable. Should you decide to abandon this workflow (:worried:) for a different mechanism, engine, or what not, all of your code will happily port to whatever other project / flow you are working with and so will all your testing making it a win win.
You can also find various library examples inside the tests/UnitTests or the tests/RabbitMQ.Console.Test project.
Test Server: Windows 11
RabbitMQ Server: v3.13
Erlang: v26.2.3
A library that focuses on RabbitMQ connection and channel management to create fault tolerant Publishers and Consumers.
Formerly called CookedRabbit.Core/Tesseract.
A library that provides the base magic Dataflows for RabbitMQ.Dataflows.
BufferBlock<TIn>These libraries are here to help you build powerful Dataflows for your messages.
A library that has a collection of .NET ISerializationProvider or the interface to make your own.
A library that has a collection of .NET ICompressionProvider or the interface to make your own.
A library that focuses on implementing hashing.
A library that provides encryption contracts and the base AesGCM/AesCBC .NET IEncryptionProvider as
well as the interface to make your own.
A library that has a collection of .NET IMetricsProvider or the interface to make your own.
A library that provides the provides helper classes for data manipulation and transformation.
Also provides Database abstractions, a simple Dapper integration, and SqlKata integration SQL query generation.
A library that focuses on general purpose utilities and functions that simplify the coding experience.