Reo.Core.Queue.MassTransit.Abstractions 10.0.411

.NET 10.0 This package targets .NET 10.0. The package is compatible with this framework or higher. 
dotnet add package Reo.Core.Queue.MassTransit.Abstractions --version 10.0.411
                    


                    

                
NuGet\Install-Package Reo.Core.Queue.MassTransit.Abstractions -Version 10.0.411
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.411" />
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.411" />
                    


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


                    

                
#r "nuget: Reo.Core.Queue.MassTransit.Abstractions, 10.0.411"
#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.411
#: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.411
                    


                            Install as a Cake Addin
                        

                    

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


                            Install as a Cake Tool

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.

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.411 108 10/30/2026
10.0.410 105 10/26/2026
10.0.409 102 10/26/2026
10.0.406 127 10/23/2026
10.0.405 98 10/23/2026
10.0.401 99 10/22/2026
10.0.400 99 10/22/2026
10.0.399 106 10/22/2026
10.0.396 105 10/22/2026
10.0.395 182 10/20/2026
10.0.394 103 10/20/2026
10.0.392 125 10/16/2026
10.0.391 107 10/15/2026
10.0.389 149 10/8/2026
10.0.387 135 10/7/2026
10.0.386 107 10/7/2026
10.0.384 102 10/6/2026
10.0.383 136 10/5/2026
10.0.382 109 10/5/2026
10.0.380 115 10/5/2026
Loading failed