LighBus

LightBus is a simple implementation for sending asynchronous messages oneway or with return for .NET applications.

Installation

The library is available via NuGet packages:

Package Manager

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

.NET CLI

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

Getting Starter

Asp.Net Core

If you are using Asp.Net core, just install LightBus.Microsoft.DependencyInjection , this package enables you to automatically register the message handler, just using the sintax below.

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

Creating Message and Handlers

Message

To create a message is very simple, you just need a class and implement IMessage Interface like below

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

MessageHandler

Like a Message, you just need a class and implement: IMessageHandler<TMessage> where TMessage: IMessage Interface like below

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

Sending Message

to trigger a message you will need to inject the ILightBus Interface and use PushAsync<TMessage>(TMessage) to dispatch a message like below

[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";
    }
}

Creating Message and Handlers With Response

Message Response

To create a message is very simple, you just need a class and implement IMessage<out Response> Interface like below

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

MessageHandlerResponse

Like a Message, you just need a class and implement: IMessageHandler<TMessage, TResponse> where TMessage: IMessage<TResponse> Interface like below

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

Sending Message With Response

to trigger a message you will need to inject the ILightBus Interface and use Task<TResponse> SendAsync<TMessage, TResponse>(Action<TMessage> messageHandler = null) to dispatch a message like below

[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");
    }
}