NServiceBus延遲消息處理

Question

我有一個NServiceBus應用程序，由於某些外部事件未發生，可能無法處理給定消息。因爲這個其他事件不是NSB事件，所以我無法正確實施傳說。

但是，我不是將消息重新排隊（這將導致一個循環，直到發生外部事件），而是將消息封裝在另一條消息（DelayMessage）中，然後排隊。 DelayMessage由不同的服務提取並放置在數據庫中，直到重試間隔到期。此時，延遲服務將消息重新排隊在原始隊列上，以便可以進行另一次嘗試。

但是，如果該外部事件還沒有發生，這可能會發生多次，並且在甚至從不發生的情況下，我想限制消息所需的往返次數。這意味着DelayMessage具有MaxRetries屬性，但延遲服務將原始消息排隊以便重試時會丟失該屬性。

我錯過了什麼其他選項？我很高興接受這個問題有完全不同的解決方案。

Answer 1

考慮實施存儲第一條消息的saga，直到第二條消息到達爲止。您可能還希望該傳奇也打開timeout，以便您的過程不會無限期地等待，如果第二條消息丟失或什麼的。