Program.cs

using MetricsExample;
using MetricsExample.Model;
using Microsoft.Extensions.Hosting;
using Motor.Extensions.Conversion.SystemJson;
using Motor.Extensions.Hosting.Consumer;
using Motor.Extensions.Hosting.RabbitMQ;
using Motor.Extensions.Utilities;

await MotorHost
    .CreateDefaultBuilder()
    // Configure the types of the input and output messages
    .ConfigureNoOutputService<InputMessage>()
    // Add the incomming communication module.
    .ConfigureConsumer<InputMessage>(
        (_, builder) =>
        {
            // In this case the messages are received from RabbitMQ
            builder.AddRabbitMQ();
            // The encoding of the incoming message, such that the handler is able to deserialize the message
            builder.AddSystemJson();
        }
    )
    .UseStartup<Startup>()
    .RunConsoleAsync();