I'm using MassTransit 7.0.6
with consumer Sagas and Azure Service Bus as a message broker.
My saga is orchestrating a list of events, I noticed with Azure Service Bus that I still have incoming messages even when I complete my action with all related commands in saga.
MassTransit Messages and Topics ScreenShot
Here is my configuration:
services.AddMassTransit(x =>
{
x.AddSaga<MySaga>().InMemoryRepository();
x.AddConsumer<Consumer1>();
x.AddConsumer<Consumer2>();
x.AddConsumer<Consumer3>();
x.SetKebabCaseEndpointNameFormatter();
x.UsingAzureServiceBus((context, cfg) =>
{
cfg.UseInMemoryOutbox();
cfg.Host(Configuration["ServiceBus:ConnectionString"]);
cfg.ConfigureEndpoints(context);
});
});
services.AddMassTransitHostedService();
I thought I'm not acknowledging all messages, I may miss something to do it more proper.
If you have any recommendation ideas thanks for sharing and challenging me!
与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…