У меня есть список сообщений в шине для одного и того же сеанса Saga, я хочу обновить одну и ту же Saga для каждого сообщения, которое получает Saga, сообщения принимаются в одно и то же время для одного и того же сеанса.Но чтобы управлять параллелизмом и избежать исключения параллелизма, я хочу использовать эту функцию сеанса, которая предоставляет служебную шину Azure, https://docs.microsoft.com/en-us/azure/service-bus-messaging/message-sessions Как это сделать с MassTransit, это эквивалентно?
Тот же вопрос, но не с Masstransit: Сервисная шина Azure - избегайте параллельной обработки сообщений с одного устройства
Спасибо
Этот модульный тест настраивает сообщение и приемную конечную точку, поэтому для очереди требуется сеанс для обеспечения параллелизма.
https://github.com/MassTransit/MassTransit/blob/develop/src/MassTransit.AzureServiceBusTransport.Tests/Session_Specs.cs
Существует также пример, показывающий, как использовать служебную шину Azure в качестве репозитория саги, используя состояние сеанса для сериализации и сохранения экземпляра саги:
https://github.com/MassTransit/MassTransit/blob/develop/src/MassTransit.AzureServiceBusTransport.Tests/SagaRepository_Specs.cs