Welcome to OStack Knowledge Sharing Community for programmer and developer-Open, Learning and Share
Welcome To Ask or Share your Answers For Others

Categories

0 votes
1.2k views
in Technique[技术] by (71.8m points)

azureservicebus - MassTransit Azure Service Bus acknowledge messages

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!


与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
Welcome To Ask or Share your Answers For Others

1 Answer

0 votes
by (71.8m points)
等待大神答复

与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
Welcome to OStack Knowledge Sharing Community for programmer and developer-Open, Learning and Share
Click Here to Ask a Question

2.1m questions

2.1m answers

60 comments

57.0k users

...