Обработка сообщений с задержкой NServiceBus

Question

У меня есть приложение NServiceBus, для которого данное сообщение не может быть обработано из-за какого-либо внешнего события, которое не произошло. Поскольку это другое событие не является событием NSB, я не могу правильно реализовать саги.

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

Однако это может случиться более одного раза, если это внешнее событие все еще не состоялось, а в случае, когда это даже никогда не происходит, я хочу ограничить количество круглых поездок, которые принимает сообщение. Это означает, что свойство DelayMessage имеет свойство MaxRetries, но оно теряется, когда служба задержки ставит в очередь исходное сообщение для повтора.

Какие еще варианты мне не хватает? Я рад принять, что существует совершенно другое решение этой проблемы.

Answer 1

Рассмотрите возможность внедрения saga, который хранит это первое сообщение, удерживая его до получения второго сообщения. Вы также можете захотеть, чтобы сага открыла timeout, чтобы ваш процесс не стал ждать бесконечно, если это второе сообщение потерялось или что-то в этом роде.