Reo.Core.Queue.MassTransit.Models
10.0.30
See the version list below for details.
dotnet add package Reo.Core.Queue.MassTransit.Models --version 10.0.30
NuGet\Install-Package Reo.Core.Queue.MassTransit.Models -Version 10.0.30
<PackageReference Include="Reo.Core.Queue.MassTransit.Models" Version="10.0.30" />
<PackageVersion Include="Reo.Core.Queue.MassTransit.Models" Version="10.0.30" />
<PackageReference Include="Reo.Core.Queue.MassTransit.Models" />
paket add Reo.Core.Queue.MassTransit.Models --version 10.0.30
#r "nuget: Reo.Core.Queue.MassTransit.Models, 10.0.30"
#:package Reo.Core.Queue.MassTransit.Models@10.0.30
#addin nuget:?package=Reo.Core.Queue.MassTransit.Models&version=10.0.30
#tool nuget:?package=Reo.Core.Queue.MassTransit.Models&version=10.0.30
Reo.Core.Queue.MassTransit.Models
Описание пакета
Reo.Core.Queue.MassTransit.Models — это библиотека, предназначенная для интеграции с системами сообщений на основе MassTransit, используемой в распределённых системах и микросервисах. Пакет предоставляет модели, события и инфраструктурные классы для обработки асинхронных операций, управления связями объектов инфраструктуры и взаимодействия с внешними сервисами. Он решает задачи, связанные с обработкой событий, координацией между компонентами и обеспечением надёжной передачи данных между сервисами.
Основные компоненты
1. InfrastructureObjectReferenceBase
Абстрактный базовый класс для событий, связанных с объектами инфраструктуры. Определяет тип ссылки (
ExternalReferenceType) и базовую логику обработки событий.
2. AsyncInfrastructureObjectReferenceEvent
Модель для асинхронных событий, связанных с объектами инфраструктуры. Используется для передачи данных между сервисами.
3. VehicleAllTrackComparisonCompleted
Событие, сигнализирующее о завершении сравнения траекторий транспортных средств. Пример использования: обработка завершения операции в системе мониторинга транспорта.
4. InfrastructureObjectReference
Модель для хранения ссылок на объекты инфраструктуры, например, на внешние сервисы или ресурсы.
5. QueueConstants
Классы с константами для имен очередей и сообщений (например, VehicleTrackComparisonCompletedQueue), используемые для
настройки интеграции с MassTransit.
Требования
- .NET версии: .NET 8.0, .NET 9.0.
- Зависимости:
Установка
NuGet Package Manager
Install-Package Reo.Core.Queue.MassTransit.Models
.NET CLI
dotnet add package Reo.Core.Queue.MassTransit.Models
Настройка
Регистрация в ASP.NET Core
Добавьте сервисы в DI-контейнер в Program.cs или Startup.cs:
var builder = WebApplication.CreateBuilder(args);
// Регистрация MassTransit и связанных моделей
builder.Services.AddMassTransit(x =>
{
x.AddConsumersFromNamespaceContaining<InfrastructureObjectReferenceBase>();
x.UsingRabbitMq((context, cfg) =>
{
cfg.Host("localhost", h => h.UseDefaultHost());
cfg.ConfigureEndpoints(context);
});
});
var app = builder.Build();
app.Run();
Конфигурационные параметры
Настройка MassTransit осуществляется через стандартные параметры, например, в appsettings.json:
{
"MassTransit": {
"Host": "rabbitmq://localhost"
}
}
Использование
Пример 1: Обработка события VehicleAllTrackComparisonCompleted
public class VehicleTrackComparisonConsumer : IConsumer<VehicleAllTrackComparisonCompleted>
{
public Task Consume(ConsumeContext<VehicleAllTrackComparisonCompleted> context)
{
var eventPayload = context.Message;
Console.WriteLine($"Сравнение траекторий завершено для события: {eventPayload.EventId}");
return Task.CompletedTask;
}
}
Пример 2: Создание события для связи объектов инфраструктуры
var referenceEvent = new AsyncInfrastructureObjectReferenceEvent
{
Type = ExternalReferenceType.Vehicle,
ObjectId = "vehicle-123",
ExternalId = "external-vehicle-456"
};
// Отправка события через MassTransit
await _bus.Publish(referenceEvent);
Лицензия
Данный пакет распространяется под лицензией MIT.
| Product | Versions 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. |
-
net10.0
- FluentValidation (>= 12.1.1)
- JetBrains.Annotations (>= 2025.2.4)
- MassTransit (>= 8.5.8 && < 9.0.0)
- MassTransit.RabbitMQ (>= 8.5.8 && < 9.0.0)
- 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)
- Polly (>= 8.5.0)
- RabbitMQ.Client (>= 7.2.0)
- Reo.Core.BaseDomainModels (>= 10.0.30)
- stbychkov.AutoLoggerMessage (>= 1.0.15)
- System.Linq.Async (>= 7.0.0)
NuGet packages (2)
Showing the top 2 NuGet packages that depend on Reo.Core.Queue.MassTransit.Models:
| Package | Downloads |
|---|---|
|
Reo.Core.AsyncOperations
Package Description |
|
|
Reo.MnoApi.Sensors
Package Description |
GitHub repositories
This package is not used by any popular GitHub repositories.
| Version | Downloads | Last Updated |
|---|---|---|
| 10.0.33 | 0 | 2/13/2026 |
| 10.0.32 | 0 | 2/13/2026 |
| 10.0.31 | 0 | 2/13/2026 |
| 10.0.30 | 30 | 2/12/2026 |
| 10.0.29 | 34 | 2/12/2026 |
| 10.0.28 | 46 | 2/11/2026 |
| 10.0.27 | 56 | 2/11/2026 |
| 10.0.26 | 78 | 2/9/2026 |
| 10.0.25 | 102 | 2/9/2026 |
| 10.0.24 | 121 | 2/9/2026 |
| 10.0.23 | 106 | 2/9/2026 |
| 10.0.22 | 108 | 2/9/2026 |
| 10.0.21 | 117 | 2/9/2026 |
| 10.0.20 | 116 | 2/9/2026 |
| 10.0.15 | 143 | 2/6/2026 |
| 10.0.14 | 134 | 2/6/2026 |
| 10.0.13 | 328 | 2/4/2026 |
| 10.0.12 | 139 | 2/3/2026 |
| 10.0.11 | 145 | 2/2/2026 |
| 10.0.10 | 148 | 1/29/2026 |