DotNetBaseQueue.RabbitMQ.Handler 9.0.0

DotNetBaseQueue

This library aims to facilitate the use of asynchronous processes in .NET projects, with an initial focus entirely on RabbitMQ.

Installation

Message Publishing

dotnet add package DotNetBaseQueue.RabbitMQ.Publish

Message Consumption by Handler

dotnet add package DotNetBaseQueue.RabbitMQ.Handler

Sending Messages

To send messages, add the following to your services:

builder.Services.AddQueuePublishSingleton(CONFIG_APPSETTINGS);

To send a message, use dependency injection to get the IQueuePublish interface and utilize the available method.

Example:

public class TestController : BaseController
{
    private readonly IQueuePublish _queuePublish;

    public TestController(IQueuePublish queuePublish)
    {
        _queuePublish = queuePublish;
    }

    [HttpPost]
    public IActionResult PostEntity(object obj)
    {
        _queuePublish.Publish(obj, CONFIG_PublishSectionQueue);

        return Ok();
    }

    [HttpPost]
    public IActionResult PostEntities(List<object> objects)
    {
        _queuePublish.PublishList(objects, CONFIG_PublishSectionQueue);

        return Ok();
    }
}

Adding a Consumer

• The message object must implement the IRabbitEvent interface or IRabbitEventRetry (for using retry).

• The class for message processing must implement the IRabbitEventHandler interface.

• Add the consumer to your .NET services using the AddWorkerConfiguration and AddHandler Methods.

Example:

Startup:

services
    .AddWorkerConfiguration(configuration, CONFIG_APPSETTINGS)
    .AddHandler<SendMessageHandler, Message>(CONFIG);

public class Message : IQueueEvent
{
    public string SenderId { get; set; }
}

public class SendMessageHandler : IQueueEventHandler<Message>
{
    public async Task HandleAsync(Message command)
    {
        // Handle the message
    }
}

Configuring appsettings.json

You can configure the appsettings.json file as follows:

Base:

  "QueueConfiguration": {
    "HostName": "",
    "Port": 5672,
    "UserName": "",
    "Password": "",
    "VirtualHost": "/"
  },

Only handler config:

  "QueueConfiguration": {
    "ExchangeName": "",
    "ExchangeType": "direct",
    "RoutingKey": "",
    "QueueName": "",
    "NumberOfWorkroles": 1,
    "CreateDeadLetterQueue": true,
    "CreateRetryQueue": true,
    "SecondsToRetry": 15,
    "NumberTryRetry": 3
  },

All:

  "QueueConfiguration": {
    "HostName": "",
    "Port": 5672,
    "VirtualHost": "/",
    "UserName": "",
    "Password": "",

    "ExchangeName": "",
    "ExchangeType": "direct",
    "RoutingKey": "",
    "QueueName": "",
    "NumberOfWorkroles": 1,
    "CreateDeadLetterQueue": true,
    "CreateRetryQueue": true,
    "SecondsToRetry": 15,
    "NumberTryRetry": 3
  },