C# MassTransit : Message retry limit exceeded on Response

Хотелось узнать бы мнение людей, имеющих опыт разрешения проблем с MassTransit (MSMQ):

Публикуем сообщения и обрабатываем соответствующие отклики:

var message = new OriginalMessage(...);
serviceBus.PublishRequest(message, context =>
            {
                context.Handle<OriginalMessageResponse>(response =>
                {
                    if (response.Reason != Response.Success)
                    {
                        // log success
                    }
                    else
                    {
                        // log failure
                    }
                });
            });

Метод PostDispatch из InboundMessageInterceptor срабатывает несколько раз для каждого ожидаемого отклика, затем выбрасывается "Message retry limit exceeded" и сообщения с типом OriginalMessageResponse падают в соотвествующую MSMQ-очередь ошибок

В доках пишут, что очередь ошибок пополняется, когда все потребители сообщений вернули ошибку или выкинули исключение, но я не вижу подобных признаков.

Анонимный обработчик откликов не срабатывает. Настораживает то, что в логах MassTransit-a нет подписок на зафэйленные сообщения (c соответствующим requestId) Все выглядит так, как будто Consumer-а нет, но при этом InboundMessageInterceptor срабатывает.

Какие-нибудь идеи о том, что следует проверить, на что обратить внимание, что могло привести к подобному?


Ответы (0 шт):