与 Masstransit 的等效会话以与 Saga 并发

Equivalent Session with Masstransit for concurrency with Saga

我在同一会话 Saga 的总线上有一个消息列表,我想为 Saga 收到的每条消息更新相同的 Saga,同一会话的消息是在同一时间接收的。但是为了管理并发并避免并发异常,我想使用提供 Azure 服务总线的会话功能, https://docs.microsoft.com/en-us/azure/service-bus-messaging/message-sessions 如何使用 MassTransit 做到这一点,它是等价的?

同样的问题,但与 Masstransit 无关:

谢谢

此单元测试设置消息和接收端点,以便队列需要 Session 来强制并发。

https://github.com/MassTransit/MassTransit/blob/develop/src/MassTransit.AzureServiceBusTransport.Tests/Session_Specs.cs

还有一个示例展示了如何使用 Azure 服务总线作为 saga 存储库,使用会话状态序列化和存储 saga 实例:

https://github.com/MassTransit/MassTransit/blob/develop/src/MassTransit.AzureServiceBusTransport.Tests/SagaRepository_Specs.cs