👁 Image
Cosmos.EventDriven.CritterStack.AzureServiceBus 1.2.3

Cosmos.EventDriven.CritterStack.AzureServiceBus

👁 NuGet

Integración de Azure Service Bus con Wolverine para implementar Event Driven Architecture (EDA) en .NET 10.

Descripción

Este paquete provee extensiones sobre WolverineOptions para configurar Azure Service Bus como broker de mensajería en aplicaciones Cosmos EDA, con soporte especial para escenarios serverless mediante publicación inline de IPrivateEvent.

Características

• HabilitarAzureServiceBusParaServerLess: Configura Azure Service Bus para proyectos serverless sin colas de sistema
• AgregarAzureServiceBusNombrado / AgregarAzureServiceBusNombradoServerless: Configura un broker nombrado (para apps que usan más de una conexión)
• PublicarEventoServerless: Publica un IEvent a un topic de Azure Service Bus de forma inline (con sobrecarga para broker nombrado)
• PublicarEventosServerless: Publica múltiples IEvent de un assembly a un topic de Azure Service Bus
• SuscribirseAEvento: Escucha una subscription de un topic con inbox duradero (con sobrecarga para broker nombrado)

Instalación

dotnet add package Cosmos.EventDriven.CritterStack.AzureServiceBus

Uso

Configurar Azure Service Bus en Wolverine (Serverless)

builder.Host.UseWolverine(opts =>
{
 opts.HabilitarAzureServiceBusParaServerLess(
 builder.Configuration.GetConnectionString("AzureServiceBus")!);

 // Publicar un evento específico a un topic
 opts.PublicarEventoServerless<PedidoCreado>("pedidos");

 // Publicar todos los IEvent del assembly a un topic
 opts.PublicarEventosServerless("mi-servicio", typeof(Program).Assembly);
});

Suscribirse a eventos de un servicio productor

builder.Host.UseWolverine(opts =>
{
 opts.HabilitarAzureServiceBusParaServerLess(
 builder.Configuration.GetConnectionString("AzureServiceBus")!);

 // Escuchar una subscription de un topic con inbox duradero
 opts.SuscribirseAEvento("mi-subscription", "pedidos");

 // Sobre un broker nombrado
 opts.AgregarAzureServiceBusNombradoServerless("ventas",
 builder.Configuration.GetConnectionString("VentasServiceBus")!);
 opts.SuscribirseAEvento("ventas", "mi-subscription", "pedidos");
});

Definir un Evento Privado

using Cosmos.EventDriven.Abstractions;

public record PedidoCreado(
 Guid PedidoId,
 string ClienteId,
 DateTime CreadoEn
) : IPrivateEvent;

Requisitos

• .NET 10.0 o superior
• Azure Service Bus accesible desde la aplicación
• Cadena de conexión configurada en appsettings.json

Licencia

Copyright © Cosmos. Todos los derechos reservados.