Consumers

A Consumer is a service that listen to events from the broker. Make sure you've read MassTransit official documentation on the topic.

Let's see an example of how we can consume a message on a Suite Module.

First we declare the consumer

class SubmitOrderConsumer : IConsumer<SubmitOrder>
{
    private readonly ILogger<SubmitOrderConsumer> logger;

    public SubmitOrderConsumer(ILogger<SubmitOrderConsumer> logger) {
        this.logger = logger;
    }

    public async Task Consume(ConsumeContext<SubmitOrder> context)
    {
        this.logger.LogInformation("Received Submit Order Event");
    }
}

The consumer needs to be in a module that depends on MassTransitModule.

internal class SampleSuiteModule : SuiteModule
{
    public override void SetupModule(IModuleBuilder builder)
    {
        base.SetupModule(builder);

        builder.DependsOn<MassTransitModule>();
    }
}