Akay.To.Messaging.Rebus 1.0.5

Akay.To.Messaging.Rebus

Proveedor de mensajería que implementa los contratos de Akay.To.Core (IMessageBus, IMessageHandler<T>) con Rebus.

¿Para qué sirve?

Para enviar comandos point-to-point y publicar eventos pub/sub con un bus real (RabbitMQ, Azure Service Bus o InMemory), con routing declarativo, retry y auto-subscribe, sin acoplar tu aplicación a Rebus.

Funcionalidades

Registro

services.AddRebusMessaging(settings?.MessagingSettings, typeof(Program).Assembly);

Si MessagingSettings es null, no registra nada (fail-safe). Registrar un segundo proveedor de IMessageBus lanza InvalidOperationException.

Transports

La cola de errores por defecto es {InputQueueName}.error, con MaxDeliveryAttempts configurable.

Routing

Los comandos ICommandMessage con route configurada se envían a su cola destino; sin route, se usan SendLocal. Los eventos IIntegrationEvent usan pub/sub de Rebus con auto-subscribe.

{
  "MessagingSettings": {
    "Transport": "RabbitMq",
    "ConnectionString": "amqp://guest:guest@localhost",
    "InputQueueName": "my-api",
    "MaxDeliveryAttempts": 3,
    "Routes": {
      "MyApp.GenerateReportMessage, MyApp.Application": "my-worker"
    }
  }
}

Handlers

Los handlers implementan IMessageHandler<T> y se descubren automáticamente de los assemblies indicados. Para registro explícito, pon AutoRegisterHandlers a false y usa:

services.AddRebusHandler<GenerateReportMessage, ReportHandler>();

Opciones de mensaje

MessageSendOptions / MessagePublishOptions: Delay (deferral de Rebus) y TimeToLive (mapeado a TimeToBeReceived). Los headers reservados de Rebus no se pueden sobrescribir.

Health check

rebus_messaging verifica que el bus esté operativo (para transporte InMemory siempre devuelve Healthy).

Documentación

Consulta docs/Messaging.md para detalles de configuración.

Changelog

1.0.5

• 2026-09-10
• Actualiza Akay.To.Core y mejora documentación en español (a1e21a8)

1.0.4

• 2026-07-28
• chore: bump Akay.To.Core to 1.1.5 (0363639)

1.0.3

• 2026-07-21
• chore: update reference to Akay.To.Core 1.1.3 (c7e8c1f)

1.0.2

• 2026-07-17
• fix: referencia duplicada a akay.to.core (67a0581)

1.0.1

• 2026-07-16
• Agregar archivos de proyecto. (68cc479)