MassTransit Экспоненциальная попытка не работает ⇐ C#

[Anonymous]

У меня есть одна проблема, так как вы можете видеть, что есть 3 потребителя, и у меня есть глобальная конфигурация без повторных и без очередей ошибок, но для Zconsumer у меня есть конкретная политика повторения. Не могли бы вы помочь мне, в чем проблема? Я видел несколько журналов и с 15:00 до сих пор (22:00) все еще дает в курсе. И почему это не ограничено? < /p>
Пожалуйста, помогите
заранее !!!
services.AddMassTransit(x =>
{
x.AddConsumer();
x.AddConsumer();

x.AddConsumer();

x.AddConfigureEndpointsCallback((context, name, cfg) =>
{
cfg.UseMessageRetry(r => r.None());
cfg.DiscardFaultedMessages();
});

x.UsingRabbitMq((ctx, cfg) =>
{
cfg.Host(context.Configuration["BrokerSettings:RabbitNode3"], h =>
{
h.Username(context.Configuration["BrokerSettings:Username"]);
h.Password(context.Configuration["BrokerSettings:Password"]);
h.UseCluster(cluster =>
{
cluster.Node(context.Configuration["BrokerSettings:RabbitNode1"]);
cluster.Node(context.Configuration["BrokerSettings:RabbitNode2"]);
});
});

cfg.ReceiveEndpoint("x-consumer-queue", e =>
{
e.ConfigureConsumer(ctx);
});

cfg.ReceiveEndpoint("y-consumer-queue", e =>
{
e.ConfigureConsumer(ctx);
});

cfg.ReceiveEndpoint("z-consumer-queue", e =>
{
e.ConfigureConsumer(ctx);

e.UseMessageRetry(r =>
{
r.Exponential(
retryLimit: 10,
minInterval: TimeSpan.FromSeconds(10),
maxInterval: TimeSpan.FromMinutes(30),
intervalDelta: TimeSpan.FromSeconds(30));
});
});
});

x.SetKebabCaseEndpointNameFormatter();
});


Подробнее здесь: https://stackoverflow.com/questions/797 ... oesnt-work