Reo.Core.Queue.MassTransit.Abstractions 10.0.28

There is a newer version of this package available.
See the version list below for details.

dotnet add package Reo.Core.Queue.MassTransit.Abstractions --version 10.0.28

NuGet\Install-Package Reo.Core.Queue.MassTransit.Abstractions -Version 10.0.28

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="Reo.Core.Queue.MassTransit.Abstractions" Version="10.0.28" />

For projects that support PackageReference, copy this XML node into the project file to reference the package.

<PackageVersion Include="Reo.Core.Queue.MassTransit.Abstractions" Version="10.0.28" />
                    

                            Directory.Packages.props

<PackageReference Include="Reo.Core.Queue.MassTransit.Abstractions" />
                    

                            Project file

For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.

paket add Reo.Core.Queue.MassTransit.Abstractions --version 10.0.28

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

#r "nuget: Reo.Core.Queue.MassTransit.Abstractions, 10.0.28"

#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.

#:package Reo.Core.Queue.MassTransit.Abstractions@10.0.28

#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.

#addin nuget:?package=Reo.Core.Queue.MassTransit.Abstractions&version=10.0.28
                    

                            Install as a Cake Addin

#tool nuget:?package=Reo.Core.Queue.MassTransit.Abstractions&version=10.0.28
                    

                            Install as a Cake Tool

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

Reo.Core.Queue.MassTransit.Abstractions

Описание пакета

Reo.Core.Queue.MassTransit.Abstractions — это библиотека для работы с сообщениями и очередями через MassTransit и * RabbitMQ*. Пакет предоставляет абстракции для создания и настройки конечных точек, отправки сообщений, а также интеграции с системами мониторинга через проверки здоровья (health checks).

Основные функции:

Упрощённая настройка отправки сообщений в RabbitMQ с использованием MassTransit.
Поддержка создания конечных точек для очередей и обработки событий.
Интеграция с проверками здоровья (health checks) для мониторинга состояния RabbitMQ-кластера.
Гибкая конфигурация через DI-контейнер (например, в ASP.NET Core).

Основные компоненты

1. EndpointBuilder

Назначение: Создание адресов конечных точек для очередей RabbitMQ.
Описание: Позволяет программно настраивать параметры очередей (например, имя, тип, атрибуты) и генерировать URI для использования в MassTransit.

2. SendEndpointProviderExtensions

Назначение: Расширение функционала ISendEndpointProvider для отправки сообщений в конкретные очереди.
Описание: Методы для асинхронного получения ISendEndpoint по имени очереди, упрощающие работу с отправкой сообщений.

3. RabbitMqHealthChecksBuilderExtensions

Назначение: Интеграция с системами мониторинга через проверки здоровья (health checks).
Описание: Добавляет проверку работоспособности RabbitMQ-кластера, используя настройки из RabbitMqClusterOptions.

4. RabbitMqClusterOptions

Назначение: Конфигурационный класс для настройки подключения к RabbitMQ.
Описание: Содержит параметры подключения (хосты, порты, логины, пароли) и настройки проверок здоровья.

Требования

Версии .NET

.NET 8.0 и выше (тестирование на .NET 8.0 и .NET 9.0).

Зависимости

MassTransit (для работы с сообщениями и очередями).
RabbitMQ.Client (для взаимодействия с RabbitMQ).
Microsoft.Extensions.Diagnostics.HealthChecks (для проверок здоровья).

Установка

NuGet Package Manager

Install-Package Reo.Core.Queue.MassTransit.Abstractions

.NET CLI

dotnet add package Reo.Core.Queue.MassTransit.Abstractions

Настройка

Регистрация в DI-контейнере (ASP.NET Core)

services.AddReoIntegrationServices<YourAssembly>();

Пример конфигурации в `appsettings.json`

{
  "RabbitMqClusterOptions": {
    "Hosts": ["rabbitmq-host:5672"],
    "Username": "guest",
    "Password": "guest"
  }
}

Регистрация проверок здоровья

services.TryAddRabbitMqCluster(new RabbitMqClusterOptions
{
    Hosts = new[] { "rabbitmq-host:5672" },
    Username = "guest",
    Password = "guest"
});

Использование

Пример 1: Отправка сообщения в очередь

public class MyService
{
    private readonly ISendEndpointProvider _sendEndpointProvider;

    public MyService(ISendEndpointProvider sendEndpointProvider)
    {
        _sendEndpointProvider = sendEndpointProvider;
    }

    public async Task SendToQueueAsync(string message)
    {
        var endpoint = await _sendEndpointProvider.GetQueueSendEndpointAsync("my-queue", CancellationToken.None);
        await endpoint.Send(new MyMessage { Content = message });
    }
}

Пример 2: Проверка работоспособности RabbitMQ

// В Startup.cs или Program.cs (ASP.NET Core)
services.AddHealthChecks()
    .TryAddRabbitMqCluster(new RabbitMqClusterOptions
    {
        Hosts = new[] { "rabbitmq-host:5672" },
        Username = "guest",
        Password = "guest"
    });

Лицензия

Данный пакет распространяется под лицензией MIT.

Product	Compatible and additional computed target framework versions.
.NET	net10.0 is compatible. net10.0-android was computed. net10.0-browser was computed. net10.0-ios was computed. net10.0-maccatalyst was computed. net10.0-macos was computed. net10.0-tvos was computed. net10.0-windows was computed.

Compatible target framework(s)

Included target framework(s) (in package)

Learn more about Target Frameworks and .NET Standard.

net10.0
- AspNetCore.HealthChecks.Rabbitmq (>= 9.0.0)
- AspNetCore.HealthChecks.UI.Client (>= 9.0.0)
- FluentValidation (>= 12.1.1)
- FluentValidation.AspNetCore (>= 11.3.1)
- Flurl (>= 4.0.0)
- Flurl.Http (>= 4.0.2)
- JetBrains.Annotations (>= 2025.2.4)
- MassTransit (>= 8.5.8 && < 9.0.0)
- MassTransit.RabbitMQ (>= 8.5.8 && < 9.0.0)
- Microsoft.AspNetCore.Mvc.NewtonsoftJson (>= 10.0.2)
- Microsoft.Bcl.AsyncInterfaces (>= 10.0.2)
- Microsoft.Extensions.Configuration (>= 10.0.2)
- Microsoft.Extensions.Configuration.Abstractions (>= 10.0.2)
- Microsoft.Extensions.Configuration.Binder (>= 10.0.2)
- Microsoft.Extensions.DependencyInjection (>= 10.0.2)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 10.0.2)
- Microsoft.Extensions.Hosting.Abstractions (>= 10.0.2)
- Microsoft.Extensions.Http.Polly (>= 10.0.2)
- Microsoft.Extensions.Logging (>= 10.0.2)
- Microsoft.Extensions.Logging.Abstractions (>= 10.0.2)
- Microsoft.Extensions.Options (>= 10.0.2)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 10.0.2)
- Newtonsoft.Json (>= 13.0.4)
- Polly (>= 8.5.0)
- RabbitMQ.Client (>= 7.2.0)
- RedLock.net (>= 2.3.2)
- Reo.Core.BaseDomainModels (>= 10.0.28)
- Reo.Core.HealthCheck (>= 10.0.28)
- Reo.Core.Hosting (>= 10.0.28)
- Reo.Core.Validation (>= 10.0.28)
- stbychkov.AutoLoggerMessage (>= 1.0.15)
- Swashbuckle.AspNetCore (>= 10.1.2)
- System.Configuration.ConfigurationManager (>= 10.0.2)
- System.Linq.Async (>= 7.0.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
10.0.30	0	2/12/2026
10.0.29	0	2/12/2026
10.0.28	28	2/11/2026
10.0.27	42	2/11/2026
10.0.26	79	2/9/2026
10.0.25	78	2/9/2026
10.0.24	79	2/9/2026
10.0.23	81	2/9/2026
10.0.22	76	2/9/2026
10.0.21	78	2/9/2026
10.0.20	77	2/9/2026
10.0.15	84	2/6/2026
10.0.14	80	2/6/2026
10.0.13	84	2/4/2026
10.0.12	81	2/3/2026
10.0.11	84	2/2/2026
10.0.10	85	1/29/2026
10.0.9	87	1/29/2026
10.0.8	92	1/27/2026
10.0.6	90	1/26/2026