Pemvedr.Common.Bus.Bootstrapper 0.1.20241031.1

#«Pemvedr.Common.Bus.Bootstrapper»

Structure

Examples

Create message, here a command.

public class ProcessEntry : Command
{
    public ProcessEntry(AddEntry logEntry) : base(logEntry.Created, RetryPolicy.Factory.DefaultRetries())
    {
        LogEntry = logEntry;
    }

    public AddEntry LogEntry { get; }
}

Create a handler for the message

public class AddEntryHandler : CommandHandler<ProcessEntry>
{
    private readonly ILog _log;

    public AddEntryHandler(ILog log, ....)
    {
        _log = log.For(this);
    }
        
    public override Task Handle(ProcessEntry message)
    {
        ...
    }
}

Create a module which returns the handler

public class AddEntryModule : IBusModule
{
    public IReadOnlyCollection<ICommandHandler> GetCommandHandlers(IIocContainer container) => new ICommandHandler[]{ container.Get<AddEntryHandler>() };

    public IReadOnlyCollection<IEventHandler> GetEventHandlers(IIocContainer container) => new IEventHandler[0];

    public IReadOnlyCollection<Saga> GetSagas(IIocContainer container) => new Saga[0];
}

Optional: Register classes in Startup

public void ConfigureServices(IServiceCollection services) =>
    services
        .AddTransient<IBusModule, AddEntryModule>()
        .AddSingleton<IBus, SimpleBusBootstrapper>();

Send messages to the bus

public class EntryReceiver
{
    private readonly IBus _bus;

    public EntryReceiver(IBus bus)
    {
        _bus = bus;
    }

    public async Task ProcessEntry(AddEntry logEntry)
    {
        await _bus.Send(new ProcessEntry(logEntry));
    }
}

Development hints

none

See also

none