YITC.DotNetCore.RabbitMQ
16.26.0
There is a newer version of this package available.
See the version list below for details.
See the version list below for details.
dotnet add package YITC.DotNetCore.RabbitMQ --version 16.26.0
NuGet\Install-Package YITC.DotNetCore.RabbitMQ -Version 16.26.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="YITC.DotNetCore.RabbitMQ" Version="16.26.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add YITC.DotNetCore.RabbitMQ --version 16.26.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: YITC.DotNetCore.RabbitMQ, 16.26.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 YITC.DotNetCore.RabbitMQ as a Cake Addin #addin nuget:?package=YITC.DotNetCore.RabbitMQ&version=16.26.0 // Install YITC.DotNetCore.RabbitMQ as a Cake Tool #tool nuget:?package=YITC.DotNetCore.RabbitMQ&version=16.26.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>
{
void Publish(T obj);
void Subscribe(Action<T> action);
}
Queue<T>
public abstract class Queue<T> : IQueue<T>
{
protected Queue(Connection connection) { }
public void Publish(T obj) { }
public void Subscribe(Action<T> 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.Publish(product);
Subscriber
IProductQueue productQueue = new ProductQueue(new Connection("localhost", 5672, "admin", "P4ssW0rd!"));
productQueue.Subscribe(product => Handle(product));
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net6.0 is compatible. net6.0-android was computed. net6.0-ios was computed. net6.0-maccatalyst was computed. net6.0-macos was computed. net6.0-tvos was computed. net6.0-windows was computed. net7.0 was computed. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. 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.
-
net6.0
- RabbitMQ.Client (>= 6.2.4)
- YITC.DotNetCore.Extensions (>= 16.26.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 |
---|---|---|
16.30.0.4 | 515 | 4/15/2022 |
16.26.0.3 | 438 | 3/17/2022 |
16.26.0.2-yitc | 203 | 3/16/2022 |
16.26.0 | 441 | 3/16/2022 |
16.26.0-yitc | 194 | 3/16/2022 |