Basic.RabbitMQ 1.1.0

Basic.RabbitMQ

.NET library that simplifies RabbitMQ usage and works with the Direct Exchange type.

Quick Start

The usage of Basic.RabbitMQ is quite simple.

1. Install Basic.RabbitMQ NuGet package from here.

PM> Install-Package Basic.RabbitMQ

2. Add services.AddRabbitMQClient(Configuration);

builder.Services.AddRabbitMQClient(Configuration);

3. Add the necessary information to the appsettings.json file.

   "MessageBrokerOptions": {
    "HostName": "",
    "UserName": "",
    "Password": "",
    "ExchangeName": "",
    "VirtualHost": ""
  }

4. And start using it. And that's it.

Producer

[ApiController]
public class ProducerController : ControllerBase
{
    private readonly IMessageProducer _messageProducer;

    public ProducerController(IMessageProducer messageProducer)
    {
        _messageProducer = messageProducer;
    }

    [HttpPost("/sendMessage")]
    public Task<IActionResult> SendEmail(string message)
    {
        _messageProducer.SendMessage("Test_Queue", "Test_Routing_Key", message);
        return Task.FromResult<IActionResult>(Ok());
    }
}

Consumer

var messageConsumer = serviceProvider.GetService<IMessageConsumer>();

var channel = messageConsumer?.Channel("Test_Queue", "Test_Routing_Key");

var basicConsumer = messageConsumer?.GetConsumer(channel);

basicConsumer!.Received += BasicConsumerReceived;

Task BasicConsumerReceived(object sender, BasicDeliverEventArgs @event)
{
    var message = Encoding.UTF8.GetString(@event.Body.ToArray());

    Console.WriteLine($" [>] Received {message}");

    channel?.BasicAck(@event.DeliveryTag, false);

    return Task.CompletedTask;
}