© 2026 Hedgehog Software, LLC

TwitterGitHubDiscord
More
CommunitiesDocsAboutTermsPrivacy
Search
Star
Setup for Free
C#C
C#•3y ago
Tim_

MassTransit: Consumers not getting called

I'm having trouble setting up masstransit. For some reason my consumers aren't getting called. The published events are saved to the database but they're not getting sent to rabbitmq for some reason.

        services.AddMassTransit(opt =>
        {
            opt.SetKebabCaseEndpointNameFormatter();
            
            opt.AddConsumer<UserRegisteredEventHandler>();
            
            opt.AddEntityFrameworkOutbox<TContext>(o =>
            {
                o.QueryDelay = TimeSpan.FromSeconds(1);
                
                o.UsePostgres();
                o.UseBusOutbox();
            });
            

            opt.UsingRabbitMq((context, o) =>
            {
                o.Host("localhost", "/", h =>
                {
                    h.Username("user123");
                    h.Password("pass123");
                });
                
                o.ConfigureEndpoints(context);
            });
        });
        services.AddMassTransit(opt =>
        {
            opt.SetKebabCaseEndpointNameFormatter();
            
            opt.AddConsumer<UserRegisteredEventHandler>();
            
            opt.AddEntityFrameworkOutbox<TContext>(o =>
            {
                o.QueryDelay = TimeSpan.FromSeconds(1);
                
                o.UsePostgres();
                o.UseBusOutbox();
            });
            

            opt.UsingRabbitMq((context, o) =>
            {
                o.Host("localhost", "/", h =>
                {
                    h.Username("user123");
                    h.Password("pass123");
                });
                
                o.ConfigureEndpoints(context);
            });
        });


public class UserRegisteredEventHandler : IConsumer<UserRegisteredEvent>
{
    private readonly ILogger<UserRegisteredEvent> _logger;

    public UserRegisteredEventHandler(ILogger<UserRegisteredEvent> logger)
    {
        _logger = logger;
    }

    public Task Consume(ConsumeContext<UserRegisteredEvent> context)
    {
        _logger.LogInformation(context.Message.ToString());
        return Task.CompletedTask;
    }
}
public class UserRegisteredEventHandler : IConsumer<UserRegisteredEvent>
{
    private readonly ILogger<UserRegisteredEvent> _logger;

    public UserRegisteredEventHandler(ILogger<UserRegisteredEvent> logger)
    {
        _logger = logger;
    }

    public Task Consume(ConsumeContext<UserRegisteredEvent> context)
    {
        _logger.LogInformation(context.Message.ToString());
        return Task.CompletedTask;
    }
}


Output when publishing an event
17:32 [Information] (Users) MassTransit
Configured endpoint "user-registered-event-handler", Consumer: "Shared.Infrastructure.Messaging.UserRegisteredEventHandler"
17:32 [Information] (Users) Users.Application.Commands.RegisterUser.Handler
At RegisterUser
17:32 [Information] (Users) MassTransit
Configured endpoint "user-registered-event-handler", Consumer: "Shared.Infrastructure.Messaging.UserRegisteredEventHandler"
17:32 [Information] (Users) Users.Application.Commands.RegisterUser.Handler
At RegisterUser
C# banner
C#Join
We are a programming server aimed at coders discussing everything related to C# (CSharp) and .NET.
61,871Members
Resources

Similar Threads

Was this page helpful?
Recent Announcements

Similar Threads

MassTransit: UseConsumeFilter throws nullreference exception on startup if I have batch consumers
C#CC# / help
2y ago
❔ Is it Possible to Consume a Queue Message by Multiple Consumers ( RabbitMQ & MassTransit ) ?
C#CC# / help
3y ago
❔ Hello, MassTransit Problem
C#CC# / help
3y ago
✅ MassTransit with RabbitMQ Exception
C#CC# / help
3y ago