NServiceBus verzögerte Nachrichtenverarbeitung

Question

Ich habe eine NServiceBus-Anwendung, für die eine bestimmte Nachricht möglicherweise aufgrund eines externen Ereignisses nicht verarbeitet werden kann. Da dieses andere Ereignis kein NSB-Ereignis ist, kann ich sagas nicht ordnungsgemäß implementieren.

Anstatt die Nachricht einfach neu einzureihen (was eine Schleife verursachen würde, bis dieses externe Ereignis aufgetreten ist), wickle ich die Nachricht in eine andere Nachricht (DelayMessage) und stehe stattdessen in die Warteschlange. Die DelayMessage wird von einem anderen Dienst abgerufen und in einer Datenbank gespeichert, bis das Wiederholungsintervall abläuft. An diesem Punkt reiht der Verzögerungsdienst die Nachricht in der ursprünglichen Warteschlange erneut ein, so dass ein weiterer Versuch unternommen werden kann.

Dies kann jedoch mehr als einmal passieren, wenn das externe Ereignis noch nicht stattgefunden hat, und in dem Fall, dass das nie passiert, möchte ich die Anzahl der Rundreisen der Nachricht begrenzen. Dies bedeutet, dass DelayMessage eine MaxRetries-Eigenschaft besitzt, die jedoch verloren geht, wenn der Verzögerungsdienst die ursprüngliche Nachricht für die Wiederholung in die Warteschlange stellt.

Welche anderen Optionen vermisse ich? Ich bin glücklich zu akzeptieren, dass es eine völlig andere Lösung für dieses Problem gibt.

Answer 1

Erwägen Sie, eine saga zu implementieren, die diese erste Nachricht speichert und festhält, bis die zweite Nachricht eintrifft. Sie möchten vielleicht auch, dass die Saga ein timeout öffnet, so dass Ihr Prozess nicht unbegrenzt warten wird, wenn diese zweite Nachricht verloren gegangen ist oder etwas.