Expero.Libraries.CSharp.RabbitMQ

Пакет для более удобной работы с RabbitMQ.

Пакет содержит:

• Фабрику для работы с RabbitMQ;
• Методы прямого доступа к IConnection и IModel;
• HealthCheck сервис для RabbitMQ;

IMesagesQueueFactory.

Для работы с RabbitMQ может использоваться IMesagesQueueFactory.

Пример подключения:

var rabbitMQConnectionSettings = new RabbitMQConnectionSettings(){/* ... */};
services.AddExperoRabbitMQMessagesQueue(rabbitMQConnectionSettings);

После этого можно будет получить IMessagesQueueFactory через DI.

Получение IConnection из IMessagesQueueFactory.

У IMessagesQueueFactory можно полчить доступ к IConnection через метод GetConnection()

Пример использования:

var factory = context.GetService<IMessagesQueueFactory>();
var connection = factory.GetConnection();

Получение IModel из IMessagesExchange И IMessagesQueue.

У IMessagesExchange, IMessagesQueue можно полчить доступ к IModel через метод GetModel()

Пример использования:

var exchange = factory.Create(Exchange);
var model1 = exchange.GetModel();

var queue = factory.Create(/* ... */);
var model2 = queue.GetModel();

HealthCheck.

В проекте реализован HealthCheck, который позволяет проверить доступность хоста RabbitMQ.

var rabbitMQConnectionString = /* ... */;
var healthCheckTimeout = 30;

services.AddHealthChecks()

        .AddExperoRabbitMQHealthCheck(
            connectionString: rabbitMQConnectionString, 
            name: "RabbitMQ", 
            tags: new[] { "dependecies", "rabbitmq" },
            timeout: healthCheckTimeout);

// ...

// Обязательно надо добавить сервис для проверки доступности RabbitMQ
services.AddExperoRabbiMQHealthCheckServices();