在 MassTransit 上动态创建队列

Question

我有一个特定的 RabbitMQ 场景，它需要动态创建队列并绑定到交换器，这些也是动态创建的（不是我创建的）。此创建和绑定由新的 SignalR 订阅触发。

本期：https://github.com/MassTransit/MassTransit/issues/398是关于它的，但我仍然不知道答案。

似乎公共交通在移动中创造事物时不是很灵活。我怎样才能做到这一点？如果我停止总线并重新创建所有队列和绑定以及新的队列和绑定，然后再次启动总线会怎样？

提前致谢。

Answer 1

接收端点可以通过总线连接，如图in the documentation。

例如：

var handle = bus.ConnectReceiveEndpoint("queue-name", x =>
{
    x.Consumer<SomeConsumer>();
})

// the code below waits for the receive endpoint to be ready
// and throws an exception if a fault occurs

var ready = await handle.Ready;

在 MassTransit 上动态创建队列

Creating queues dynamical on MassTransit

masstransit

rabbitmq

signalr