0

我正在使用 Rhino 服务总线,我有两个 saga,SaveCustomerSaga 和 ProcessReceiptSaga,这两个操作都将 UpdateInvoicesCommand 发送到标准消息使用者。在更新发票之前,两个传奇都没有完成。两个 sagas 都实现了 Orchestrates<'InvoicesUpdated> 来完成。相同的 CorrelationId 用于所有消息。

然而,当 UpdateInvoicesCommand 的消费者回复消息 InvoicesUpdated 时,它被分派给两个 Sagas!事件虽然其中一个尚未启动并且 CorrelationId 属于另一个已经启动的 Saga。

它不应该只将它发送到具有匹配 CorrelationId 的适当 Saga 吗?是否有解决方法或拦截我可以执行此行为?

(使用 v2.3.0,但是快速查看提交历史似乎不是与此相关的新更改。)

4

0 回答 0