MassTransitConfig

MassTransitConfig.cs

services.AddMassTransit(x =>
{
    x.AddConsumer<MyMessageConsumer>();
    x.AddBus(provider => Bus.Factory.CreateUsingInMemory(cfg =>
    {
        cfg.UseHealthCheck(provider);
        cfg.ReceiveEndpoint("mymessage-endpoint", ep =>
        {
            ep.ConfigureConsumer<MyMessageConsumer>(provider);
        });
    }));
});
services.AddMassTransitHostedService();