Код: Выделить всё
services.AddMassTransit(x =>
{
x.AddConsumer();
x.UsingAzureServiceBus((context, cfg) =>
{
cfg.UseMessageRetry(f =>
{
f.Interval(3, TimeSpan.FromSeconds(1));
});
cfg.Host($"sb://{options.Url}", x =>
{
x.TokenCredential = AzureCredentials.GetCredentials();
});
cfg.ReceiveEndpoint("dedupe-queue", e =>
{
e.AutoStart = true;
e.ConfigureConsumer(context);
});
cfg.ConfigureEndpoints(context);
});
});
Подробнее здесь: https://stackoverflow.com/questions/794 ... ance-issue