MassTransit与RabbitMQ的连接事件

14ifxucb  于 2023-03-30  发布在  RabbitMQ
关注(0)|答案(1)|浏览(172)

我想问一下MassTransit是否有通知RabbitMQ连接状态更改的客户端应用程序。我检查了IBusObserver,但没有MassTransit与RabbitMQ断开连接时的信息。
这是一个重要的函数,因为在断开和重新连接的情况下,我必须发送一条包含应用程序当前状态的消息。

zz2j4svz

zz2j4svz1#

原始答案是关于MT 6的。

您需要使用IReceiveEndpointObserver示例,在配置端点时附加观察者:

Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    // host and other things
    ...
    cfg.ReceiveEndpoint("my_endpoint", ep =>
    {
        // consumers
        ...
        ep.ConnectReceiveEndpointObserver(observer);
    }
}

MT 8允许注册端点观察者

来自文档:

services.AddReceiveEndpointObserver<ReceiveEndpointObserver>();

相关问题