PulseBus.RabbitMQ
1.1.1
dotnet add package PulseBus.RabbitMQ --version 1.1.1
NuGet\Install-Package PulseBus.RabbitMQ -Version 1.1.1
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="PulseBus.RabbitMQ" Version="1.1.1" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="PulseBus.RabbitMQ" Version="1.1.1" />
<PackageReference Include="PulseBus.RabbitMQ" />
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add PulseBus.RabbitMQ --version 1.1.1
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: PulseBus.RabbitMQ, 1.1.1"
#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.
#:package PulseBus.RabbitMQ@1.1.1
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=PulseBus.RabbitMQ&version=1.1.1
#tool nuget:?package=PulseBus.RabbitMQ&version=1.1.1
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
PulseBus.RabbitMQ
A RabbitMQ provider for PulseBus, the minimalistic, extensible, and provider-agnostic messaging abstraction for .NET.
✨ Features
- Asynchronous Producer and Consumer: Efficient and asynchronous message handling.
- Resilient Connection Handling: Robust connection management to ensure message delivery.
- Manual ACK/NACK: Granular control over message acknowledgment.
- Middleware Pipeline: Extend and customize message processing.
- Idempotency Support: Prevents duplicate message processing.
- Retry Policies: Configure automatic retries for failed messages.
- Metadata & Headers: Full support for message metadata and custom headers.
- Fully Compatible with PulseBus Core: Seamless integration with the PulseBus ecosystem.
📦 Installation
Install the PulseBus.RabbitMQ NuGet package:
dotnet add package PulseBus.RabbitMQ
🚀 Usage
Configure PulseBus with RabbitMQ
Integrate RabbitMQ into your PulseBus configuration:
services.AddPulseBus(builder =>
{
builder.UseRabbitMq(options =>
{
options.Host = "localhost";
options.Username = "guest";
options.Password = "guest";
});
});
Publish a Message
Send messages using the configured bus:
await bus.PublishAsync("user.created", new UserCreated { Id = 1 });
Consume a Message
Subscribe to messages and process them:
bus.Subscribe<UserCreated>("user.created", async (msg, ctx) =>
{
Console.WriteLine($"User created: {msg.Id}");
await ctx.AcknowledgeAsync();
});
💖 Support
This project is developed and maintained by Andrés Mariño. If you find this library useful, consider supporting its continued development:
- Bitcoin (BTC):
bc1p9zqgxghkjhauruhsza9n382e6kp5tpj4xtzu2csv4mypsdtdc4tqvdyg86 - Ko-fi:
📄 License
This project is licensed under the MIT License.
| Product | Versions 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. net9.0 is compatible. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
net10.0
- PulseBus (>= 1.1.1)
- PulseBus.Extensions (>= 1.0.1)
- RabbitMQ.Client (>= 7.2.1)
-
net8.0
- PulseBus (>= 1.1.1)
- PulseBus.Extensions (>= 1.0.1)
- RabbitMQ.Client (>= 7.2.1)
-
net9.0
- PulseBus (>= 1.1.1)
- PulseBus.Extensions (>= 1.0.1)
- RabbitMQ.Client (>= 7.2.1)
NuGet packages
This package is not used by any NuGet packages.
GitHub repositories
This package is not used by any popular GitHub repositories.