Reo.Core.Queue.MassTransit.Models 10.0.30

There is a newer version of this package available.
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
                    
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.Models" Version="10.0.30" />
                    
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="Reo.Core.Queue.MassTransit.Models" Version="10.0.30" />
                    
Directory.Packages.props
<PackageReference Include="Reo.Core.Queue.MassTransit.Models" />
                    
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.Models --version 10.0.30
                    
#r "nuget: Reo.Core.Queue.MassTransit.Models, 10.0.30"
                    
#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.Models@10.0.30
                    
#: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.Models&version=10.0.30
                    
Install as a Cake Addin
#tool nuget:?package=Reo.Core.Queue.MassTransit.Models&version=10.0.30
                    
Install as a Cake Tool

Reo.Core.Queue.MassTransit.Models

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

Reo.Core.Queue.MassTransit.Models — это библиотека, предназначенная для интеграции с системами сообщений на основе MassTransit, используемой в распределённых системах и микросервисах. Пакет предоставляет модели, события и инфраструктурные классы для обработки асинхронных операций, управления связями объектов инфраструктуры и взаимодействия с внешними сервисами. Он решает задачи, связанные с обработкой событий, координацией между компонентами и обеспечением надёжной передачи данных между сервисами.


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

1. InfrastructureObjectReferenceBase

Абстрактный базовый класс для событий, связанных с объектами инфраструктуры. Определяет тип ссылки ( ExternalReferenceType) и базовую логику обработки событий.

2. AsyncInfrastructureObjectReferenceEvent

Модель для асинхронных событий, связанных с объектами инфраструктуры. Используется для передачи данных между сервисами.

3. VehicleAllTrackComparisonCompleted

Событие, сигнализирующее о завершении сравнения траекторий транспортных средств. Пример использования: обработка завершения операции в системе мониторинга транспорта.

4. InfrastructureObjectReference

Модель для хранения ссылок на объекты инфраструктуры, например, на внешние сервисы или ресурсы.

5. QueueConstants

Классы с константами для имен очередей и сообщений (например, VehicleTrackComparisonCompletedQueue), используемые для настройки интеграции с MassTransit.


Требования


Установка

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 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 (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
Loading failed