LightBus

Lavo

LightBus es una implementación simple para enviar mensajes asíncronos Oneway o con retorno para aplicaciones .NET.

Instalación

La biblioteca está disponible a través de paquetes Nuget:

Administrador de paquetes

 Install-Package LightBus.Core
Install-Package LightBus.Microsoft.DependencyInjection

.NET CLI

dotnet add package LightBus.Core
dotnet add package LightBus.Microsoft.DependencyInjection

CONSIJE

ASP.NET Core

Si está utilizando ASP.NET Core, simplemente instale LightBus.Microsoft.DependencyInyection, este paquete le permite registrar automáticamente el controlador de mensajes, solo usando el sintax a continuación.

 public void ConfigureServices ( IServiceCollection services )
{
    .. .
    services . AddLightBus ( ) ;
    .. .
} 

Creación de mensajes y manejadores

Mensaje

Para crear un mensaje es muy simple, solo necesita una clase e implementa la interfaz IMessage como a continuación

 public class SampleMessage : IMessage
{
    public string Value { get ; set ; }
}

MessageHandler

Como un mensaje, solo necesita una clase e implementa: IMessageHandler<TMessage> where TMessage: IMessage Interface como a continuación

 public class SampleMessageHandler : IMessageHandler < SampleMessage >
{
    public Task HandleAsync ( SampleMessage message )
    {
        Debug . WriteLine ( message . Value ) ;
        return Task . CompletedTask ;
    }
}

Envío de mensaje

Para activar un mensaje, necesitará inyectar la interfaz ILightBus y usar PushAsync<TMessage>(TMessage) para enviar un mensaje como a continuación

 [ Route ( "" ) ]
public class ValuesController : Controller
{
    private readonly ILightBus _lightBus ;

    public ValuesController ( ILightBus lightBus )
    {
        _lightBus = lightBus ;
    }

    [ HttpGet ]
    public async Task < string > Get ( )
    {
        await _lightBus . PushAsync (
            new SampleMessage { Value = "Hello LightBus" } ) ;

        return "Ok" ;
    }
} 

Creación de mensajes y manejadores con respuesta

Respuesta de mensaje

Para crear un mensaje es muy simple, solo necesita una clase e implementa la interfaz IMessage<out Response> como a continuación

 public class SampleMessageResponse : IMessage < string >
{
    public string Value { get ; set ; }
}

MessageHandlerResponse

Como un mensaje, solo necesita una clase e implementando: IMessageHandler<TMessage, TResponse> where TMessage: IMessage<TResponse> Interface como a continuación

 public class SampleMessageHandler : IMessageHandler < SampleMessageResponse , string >
{
    public Task < string > HandleAsync ( SampleMessageResponse message )
    {
        return Task . FromResult ( $ "Hello { message . Value } " ) ;
    }
}

Enviar mensaje con respuesta

Para activar un mensaje, necesitará inyectar la interfaz ILightBus y usar Task<TResponse> SendAsync<TMessage, TResponse>(Action<TMessage> messageHandler = null) para enviar un mensaje como a continuación

 [ Route ( "" ) ]
public class ValuesController : Controller
{
    private readonly ILightBus _lightBus ;

    public ValuesController ( ILightBus lightBus )
    {
        _lightBus = lightBus ;
    }

    [ HttpGet ]
    public async Task < string > Get ( )
    {
        await _lightBus . SendAsync < SampleMessageResponse , string > ( msg => msg . Value = "LightBus" ) ;
    }
}