Создание динамических очередей на MassTransit

Question

У меня есть особый сценарий с RabbitMQ, который должен иметь динамически создаваемые очереди и привязки к обменам, которые также динамически создаются (не мной). Это создание и привязка инициируется новой подписью SignalR.

Эта проблема: https://github.com/MassTransit/MassTransit/issues/398 об этом, но я до сих пор не знаю ответа.

Похоже, что массовый транзит не очень гибкий при создании вещей в движении. Как я могу это достичь? Что делать, если я остановлю автобус и воссоздаю все очереди и привязки плюс новый, и снова запустите автобус?

Заранее спасибо.

Answer 1

Вы можете подключить дополнительные конечные точки приема на лету через объект Host из конфигурации.

Таким образом, вы можете подключить получить конечные точки, как показано в этом коде: https://github.com/MassTransit/MassTransit/blob/develop/src/MassTransit.RabbitMqTransport.Tests/ReceiveEndpoint_Specs.cs#L53

host.ConnectReceiveEndpoint ("additional_queue", х => ...);