Reo.Core.Queue.MassTransit.Models
6.0.453
See the version list below for details.
dotnet add package Reo.Core.Queue.MassTransit.Models --version 6.0.453
NuGet\Install-Package Reo.Core.Queue.MassTransit.Models -Version 6.0.453
<PackageReference Include="Reo.Core.Queue.MassTransit.Models" Version="6.0.453" />
<PackageVersion Include="Reo.Core.Queue.MassTransit.Models" Version="6.0.453" />
<PackageReference Include="Reo.Core.Queue.MassTransit.Models" />
paket add Reo.Core.Queue.MassTransit.Models --version 6.0.453
#r "nuget: Reo.Core.Queue.MassTransit.Models, 6.0.453"
#:package Reo.Core.Queue.MassTransit.Models@6.0.453
#addin nuget:?package=Reo.Core.Queue.MassTransit.Models&version=6.0.453
#tool nuget:?package=Reo.Core.Queue.MassTransit.Models&version=6.0.453
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 License © 2025 Ваше имя или организация.
| Product | Versions Compatible and additional computed target framework versions. |
|---|---|
| .NET | net8.0 is compatible. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed. net9.0 was computed. net9.0-android was computed. net9.0-browser was computed. net9.0-ios was computed. net9.0-maccatalyst was computed. net9.0-macos was computed. net9.0-tvos was computed. net9.0-windows was computed. net10.0 was computed. 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. |
-
net8.0
- AutoMapper (>= 11.0.1 && < 15.0.0)
- FluentValidation (>= 11.11.0)
- FluentValidation.AspNetCore (>= 11.3.1)
- Flurl (>= 4.0.0)
- Flurl.Http (>= 4.0.2)
- JetBrains.Annotations (>= 2024.3.0)
- MassTransit (>= 8.5.1 && < 9.0.0)
- MassTransit.RabbitMQ (>= 8.5.1 && < 9.0.0)
- Microsoft.AspNetCore.Mvc.NewtonsoftJson (>= 8.0.18)
- Microsoft.Bcl.AsyncInterfaces (>= 9.0.7)
- Microsoft.CSharp (>= 4.7.0)
- Microsoft.Extensions.Configuration (>= 9.0.7)
- Microsoft.Extensions.Configuration.Abstractions (>= 9.0.7)
- Microsoft.Extensions.Configuration.Binder (>= 9.0.7)
- Microsoft.Extensions.DependencyInjection (>= 9.0.7)
- Microsoft.Extensions.DependencyInjection.Abstractions (>= 9.0.7)
- Microsoft.Extensions.Hosting.Abstractions (>= 9.0.7)
- Microsoft.Extensions.Http.Polly (>= 9.0.7)
- Microsoft.Extensions.Logging (>= 9.0.7)
- Microsoft.Extensions.Logging.Abstractions (>= 9.0.7)
- Microsoft.Extensions.Options (>= 9.0.7)
- Microsoft.Extensions.Options.ConfigurationExtensions (>= 9.0.7)
- NEST (>= 7.17.5)
- Newtonsoft.Json (>= 13.0.3)
- Polly (>= 8.5.0)
- RabbitMQ.Client (>= 7.1.2)
- RedLock.net (>= 2.3.2)
- Reo.Core.BaseDomainModels (>= 6.0.453)
- stbychkov.AutoLoggerMessage (>= 1.0.11)
- System.Collections.Immutable (>= 9.0.7)
- System.ComponentModel.Annotations (>= 5.0.0)
- System.Configuration.ConfigurationManager (>= 9.0.7)
- System.IO.Abstractions (>= 22.0.15)
- System.IO.Pipelines (>= 9.0.7)
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.35 | 0 | 2/16/2026 |
| 10.0.34 | 0 | 2/16/2026 |
| 10.0.33 | 41 | 2/13/2026 |
| 10.0.32 | 37 | 2/13/2026 |
| 10.0.31 | 49 | 2/13/2026 |
| 10.0.30 | 58 | 2/12/2026 |
| 10.0.29 | 56 | 2/12/2026 |
| 10.0.28 | 68 | 2/11/2026 |
| 10.0.27 | 81 | 2/11/2026 |
| 10.0.26 | 95 | 2/9/2026 |
| 10.0.25 | 121 | 2/9/2026 |
| 10.0.24 | 139 | 2/9/2026 |
| 10.0.23 | 124 | 2/9/2026 |
| 10.0.22 | 125 | 2/9/2026 |
| 10.0.21 | 142 | 2/9/2026 |
| 10.0.20 | 138 | 2/9/2026 |
| 10.0.15 | 159 | 2/6/2026 |
| 10.0.14 | 150 | 2/6/2026 |
| 10.0.13 | 330 | 2/4/2026 |
| 6.0.453 | 291 | 7/17/2025 |