0

私はRhinoServiceBusを使用しており、SaveCustomerSagaとProcessReceiptSagaの2つのサガがあり、どちらの操作もUpdateInvoicesCommandを標準のメッセージコンシューマーに送信します。請求書が更新されるまで、どちらのSagasも完了しません。両方のsagasは、Orchestrates<'InvoicesUpdated>を実装して完了します。すべてのメッセージに同じCorrelationIdが使用されます。

ただし、UpdateInvoicesCommandのコンシューマーがメッセージInvoicesUpdatedで応答すると、両方のSagasにディスパッチされます。イベントの1つはまだ開始されておらず、CorrelationIdはすでに開始されているもう1つの佐賀に属しています。

CorrelationIdが一致する適切な佐賀にのみディスパッチするべきではありませんか?この動作を強制するために実行できる回避策またはインターセプトはありますか?

(v2.3.0を使用していますが、コミット履歴をざっと見てみると、これに関連する新しい変更ではないようです。)

4

0 に答える 0