.NET — Служебная шина — Перемещение сообщения в DLQ

Я использую служебную шину Azure с библиотекой Mass Transit в приложении .NET WebApi. У меня есть ServiceA, где я публикую свое сообщение StartProccess. Это сообщение также используется в конечном автомате — StartStateMachine.

Это сообщение отправляется в ServiceB (это функции Azure), где оно обрабатывается и отправляется. Я вынужден зарегистрировать потребителя для ServiceB в ServiceA, используя следующую запись, поскольку, судя по тому, что я нашел и прочитал, подписка должна уже существовать для функций Azure. Обычно я бы выполнил эту регистрацию с помощью MassTransit, но MassTransit не может создать потребителя без «привязки» — реализации потребителя. Это связано с тем, что потребитель находится в другом проекте/сервисе.

if (!(await adminClient.TopicExistsAsync(formatter.MessageName<StartProccess>()));
    adminClient.CreateTopicAsync(formatter.MessageName<StartProccess>());
    
if (!(await adminClient.SubscriptionExistsAsync(formatter.MessageName<StartProccess>()), formatterCheckFunc.ConsumerFromMessageName<StartProccess>()).Value)
    await adminClient.CreateSubscriptionAsync(new CreateSubscriptionOptions(formatter.MessageName<StartProccess>(), formatterCheckFunc.ConsumerFromMessageName<StartProccess>()) { MaxDeliveryCount = 1 });

Причина, по которой здесь указано максимальное количество доставок, заключается в том, что, когда потребитель выходит из строя из-за исключения, он не запускается снова десять раз. Я хочу добиться такого функционала, как общественный транспорт, который в случае ошибки немедленно вызывает реализацию IFault и не повторяет вызов.

Все работает так, как должно. Однако время от времени и очень редко, например, 1 раз из 100, я получаю сообщение StartProccess, которое попадает в DLQ с сообщением - превышено максимальное количество отправок. Я не понимаю, почему. Это действительно устанавливает его время от времени. Таким образом, моя государственная машина не запускается и работает очень неуклюже.

Кто-нибудь сталкивался с этой проблемой? Спасибо

Редактировать:

Обработка сообщений

    try
    {
        await _receiver.HandleConsumer<Consumer>(TopicName, SubscriptionName, message, cancellationToken);
        await messageActions.CompleteMessageAsync(message);
    }
    catch (SomeException ex)
    {
        await messageActions.AbandonMessageAsync(message);
        _log.LogWarning("LogIt");
    }
    catch
    {
        // This?
        await messageActions.CompleteMessageAsync(message);
        // Or this?
        await messageActions.DeadLetterMessageAsync(message);
        throw;
    }