HouseofCat.RabbitMQ 4.1.5

dotnet add package HouseofCat.RabbitMQ --version 4.1.5
NuGet\Install-Package HouseofCat.RabbitMQ -Version 4.1.5
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.
<PackageReference Include="HouseofCat.RabbitMQ" Version="4.1.5" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add HouseofCat.RabbitMQ --version 4.1.5
#r "nuget: HouseofCat.RabbitMQ, 4.1.5"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.
// Install HouseofCat.RabbitMQ as a Cake Addin
#addin nuget:?package=HouseofCat.RabbitMQ&version=4.1.5

// Install HouseofCat.RabbitMQ as a Cake Tool
#tool nuget:?package=HouseofCat.RabbitMQ&version=4.1.5

RabbitMQ & Dataflows

A RabbitMQ library of .NET tools to help rapidly develop well performant services or to just help manage durable connectivity with the RabbitMQ.Client!


Test Server: Windows 11
RabbitMQ Server: v3.13
Erlang: v26.2.3

Release build
Codacy Badge1
Codacy Badge2

Why Make A RabbitMQ Powered Dataflow?

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


  • Pipelines (v1) are light weight workflow-esque function-as-step executor.
    • All steps process in the order provided allowing you to still control order of execution.
    • Configurable parallelism and concurrency built-in.
    • No automatic OpenTelemetry.
    • No automatic exception catching/async error handling (thrown exceptions kill Pipelines).
  • Dataflows (v2) are the more complex, yet complete, workflow class.
    • All steps process in the order provided allowing you to still control order of execution.
    • Configurable parallelism and concurrency built-in.
    • Async processing, batch processing, consumer cloning and more!
    • Async error handling (simplify functional error handling by allowing functions to throw).
    • AutoPublish (to the next Queue) functionality built-in.
    • OpenTelemetry with native distributed tracing for Publish/Consumer.


  • A RabbitMQ ConnectionPool and ChannelPool (connection durability).
  • Supports ILogger<T> via LogHelpers static singleton.
  • Contracted IWorkState simplifies functional generic returns and integration.
  • Has ISerializationProvider support for System.Text.Json and MessagePack.
    • Easy to write your own providers.
  • Has ICompressionProvider built-in support for Gzip, Deflate, Brotli, and LZ4.
  • Has IEncryptionProvider built-in support for AesGcm and BouncyCastle AesGcm.
  • RecyclableMemoryStream options for ICompressionProvider and IEncryptionProvider.
  • Publishers AutoPublish seamless encryption/decryption steps (adds headers too).
  • Consumers allow seamless compression/decompression steps (uses headers).
  • Publisher/Consumers have built-in OpenTelemetry support.


  • All built-in steps will have integration tests that should remove concerns from end-user developer.
  • Future case will include much more complex abstract UnitTesting as time allows.
  • The developer should only need to unit test their functional business code.

Help & Guides

More to come!

You can also find various library examples inside the tests/UnitTests or the tests/RabbitMQ.Console.Test project.

Main RabbitMQ Library



A library that focuses on RabbitMQ connection and channel management to create fault tolerant Publishers and Consumers.
Formerly called CookedRabbit.Core/Tesseract.

DataFlow Library



A library that provides the base magic Dataflows for RabbitMQ.Dataflows.

  • Custom TPL Block - ChannelBock used as a Channel-based BufferBlock<TIn>
  • Has DataFlowEngine and ChannelBlockEngine.
  • Has Pipelines (Dataflow alternative).

Core Productivity Libraries

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.

  • Supports MessagePack and System.Text.Json and Newtonsoft.Json.



A library that has a collection of .NET ICompressionProvider or the interface to make your own.

  • Supports LZ4, Gzip, Brotli, and Deflate.
  • Supports RecyclableMemoryStream variants.



A library that focuses on implementing hashing.

  • Supports Argon2.



A library that provides encryption contracts and the base AesGCM/AesCBC .NET IEncryptionProvider as well as the interface to make your own.

  • Supports AesCbc via CryptoStream (good for encrypted file/memorystreams).
  • Supports .NET AesGcm 128, 192, 256 (non-streams).
  • Supports BouncyCastle AesGcm 128/192/256.
  • Supports RecyclableMemoryStream variants.

Non-Critical Library Integrations



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.

Database Connection Factory Support

  • System.Data.SqlClient
  • Microsoft.Data.SqlClient
  • MySql.Data.MySqlClient
  • Npgsq
  • MySql.Data
  • Oracle
  • SQLite



A library that focuses on general purpose utilities and functions that simplify the coding experience.

Product Compatible and additional computed target framework versions.
.NET net8.0 is compatible.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
4.1.5 72 5/2/2024
4.1.4 49 5/2/2024
4.1.3 44 5/2/2024
4.1.2 71 5/1/2024
4.1.1 89 4/29/2024
4.1.0 85 4/29/2024
4.0.0 94 4/19/2024
3.2.2 507 3/28/2024
3.2.1 461 3/28/2024
3.2.0 145 3/27/2024
3.1.3 115 3/27/2024
3.1.2 166 3/26/2024
3.1.1 327 3/26/2024
3.1.0 108 3/26/2024
3.0.0 229 3/20/2024

Major overhaul!