DotNetCore.RabbitMQ
19.7.0
dotnet add package DotNetCore.RabbitMQ --version 19.7.0
NuGet\Install-Package DotNetCore.RabbitMQ -Version 19.7.0
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="DotNetCore.RabbitMQ" Version="19.7.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add DotNetCore.RabbitMQ --version 19.7.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: DotNetCore.RabbitMQ, 19.7.0"
#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 DotNetCore.RabbitMQ as a Cake Addin #addin nuget:?package=DotNetCore.RabbitMQ&version=19.7.0 // Install DotNetCore.RabbitMQ as a Cake Tool #tool nuget:?package=DotNetCore.RabbitMQ&version=19.7.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
DotNetCore.RabbitMQ
Connection
public sealed record Connection(string HostName, int Port, string UserName, string Password);
IQueue<T>
public interface IQueue<T>
{
Task PublishAsync(T obj);
Task SubscribeAsync(Func<T, Task> action);
}
Queue<T>
public abstract class Queue<T> : IQueue<T>
{
protected Queue(Connection connection) { }
public async Task PublishAsync(T obj) { }
public async Task SubscribeAsync(Func<T, Task> action) { }
}
Example
Message
public sealed record Product(string Name);
Queue
public interface IProductQueue : IQueue<Product> { }
public class ProductQueue : Queue<Product>, IProductQueue
{
public ProductQueue(Connection connection) : base(connection) { }
}
Publisher
var product = new Product("Product");
IProductQueue productQueue = new ProductQueue(new Connection("localhost", 5672, "admin", "P4ssW0rd!"));
productQueue.PublishAsync(product).Wait();
Subscriber
IProductQueue productQueue = new ProductQueue(new Connection("localhost", 5672, "admin", "P4ssW0rd!"));
productQueue.SubscribeAsync(product => Handle(product)).Wait();
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net9.0 is compatible. |
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.
-
net9.0
- DotNetCore.Extensions (>= 19.7.0)
- RabbitMQ.Client (>= 7.0.0)
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 |
---|---|---|
19.7.0 | 84 | 11/30/2024 |