MQTTnet.EventBus

Quick Start

In your ASP.NET Core Startup.cs file add the following

public void ConfigureServices(IServiceCollection services)
{
    //...

    var retryCount = 5;
    services.AddMqttEventBus(cfg =>
    {
        cfg
            .WithClientId("Api")
            .WithTcpServer("{Ip Address}", port: 1883);

    }, retryCount);
    services.AddTransient<MyEventHandler>();
}

An EventHandler is a class that may handle one or more message types. Each message type is defined by the IIntegrationEventHandler interface, where T is the MqttApplicationMessageReceivedEventArgs.

public class MyEventHandler : IIntegrationEventHandler
{
    public Task Handle(MqttApplicationMessageReceivedEventArgs args)
    {
        //Some action...
        return Task.CompletedTask;
    }
}

Then in your application add this extension

public static class ApplicationBuilderExtansions
{
    public static IApplicationBuilder UseEventBus(this IApplicationBuilder app, Action<IEventBus> action)
    {
        var eventBus = app.ApplicationServices.GetRequiredService<IEventBus>();
        action.Invoke(eventBus);
        return app;
    }
}

and use it in your Startup.cs file

public void Configure(IApplicationBuilder app, IHostingEnvironment env)
{
    //...

    app.UseEventBus(async bus => 
    {
        await bus.SubscribeAsync<IntegrationEventHandler>("MyTopic1");
    });
}

Injected interfaces

• IEventBus
• IMqttPersisterConnection
• IEventBusSubscriptionsManager