RabbitMQ.Client.Easy
1.0.0
dotnet add package RabbitMQ.Client.Easy --version 1.0.0
NuGet\Install-Package RabbitMQ.Client.Easy -Version 1.0.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="RabbitMQ.Client.Easy" Version="1.0.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add RabbitMQ.Client.Easy --version 1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: RabbitMQ.Client.Easy, 1.0.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 RabbitMQ.Client.Easy as a Cake Addin
#addin nuget:?package=RabbitMQ.Client.Easy&version=1.0.0
// Install RabbitMQ.Client.Easy as a Cake Tool
#tool nuget:?package=RabbitMQ.Client.Easy&version=1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
RabbitMQ.Client.Easy
The goal of this project is to make using of RabbitMQ client for dotnet core much easier.
How to use
To use this project add RabbitMQ.Client.Easy to your project.
dotnet add package RabbitMQ.Client.Easy
To use it in a dotnet core WebApi project:
- Use a IServiceCollection extension method named
AddRabbitMqClient()
and pass aRabbitMqConfiguration
instance object to it as an argument.
builder.Services.AddRabbitMqClient(new RabbitMqConfiguration()
{
HostName = "localhost",
Port = 5672,
UserName = "guest",
Password = "guest"
});
- Create a class and inherit the class from
Consumer
class and override theSubscribe
method.
public class SampleConsumer : Consumer
{
public SampleConsumer(IConnection connection,
string queueName,
bool durable,
bool exclusive,
bool autoDelete,
bool autoAck) : base(connection, queueName, durable, exclusive, autoDelete,
autoAck)
{
}
public override void Subscribe(byte[]? messageAsArray)
{
var message = Encoding.UTF8.GetString(messageAsArray);
Console.WriteLine("Consumed {0}", message);
}
}
- Use
AddConsumer<>()
extension method to set the class which you created before as a consumer on a queue name.
builder.Services.AddRabbitMqClient(new RabbitMqConfiguration()
{
HostName = "localhost",
Port = 1566,
UserName = "guest",
Password = "guest"
}).AddConsumer<SampleConsumer>("sample-queue", true, true, false, false);
- In order to publish a message you should inject
IPublisher
to your controller or any another services. (For example here we injected IPublish interface in SampleController)
[ApiController]
[Route("[controller]")]
public class SampleController : ControllerBase
{
private readonly ILogger<SampleController> _logger;
private readonly IPublisher _publisher;
public SampleController(ILogger<SampleController> logger, IPublisher publisher)
{
_logger = logger;
_publisher = publisher;
}
}
- And then we use publisher builder to send a message on a queue with a routing key to an extension.
[HttpPost]
public async Task PostAction()
{
var message = "Hello from post action";
await _publisher.SetExchange("sample-exchange", "direct", true)
.SetQueue("sample-queue", true, false)
.BindQueueToExchange("sample-routing-key").PublishAsync(message);
}
Product | Versions Compatible and additional computed target framework versions. |
---|---|
.NET | net7.0 is compatible. 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.
-
net7.0
- Microsoft.Extensions.DependencyInjection (>= 8.0.0-preview.7.23375.6)
- Microsoft.Extensions.Hosting (>= 7.0.1)
- RabbitMq.Client (>= 6.5.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 |
---|---|---|
1.0.0 | 94 | 9/6/2023 |