我想问一下MassTransit是否有通知RabbitMQ连接状态更改的客户端应用程序。我检查了IBusObserver,但没有MassTransit与RabbitMQ断开连接时的信息。这是一个重要的函数,因为在断开和重新连接的情况下,我必须发送一条包含应用程序当前状态的消息。
zz2j4svz1#
原始答案是关于MT 6的。
您需要使用IReceiveEndpointObserver示例,在配置端点时附加观察者:
IReceiveEndpointObserver
Bus.Factory.CreateUsingRabbitMq(cfg => { // host and other things ... cfg.ReceiveEndpoint("my_endpoint", ep => { // consumers ... ep.ConnectReceiveEndpointObserver(observer); } }
MT 8允许注册端点观察者
来自文档:
services.AddReceiveEndpointObserver<ReceiveEndpointObserver>();
1条答案
按热度按时间zz2j4svz1#
原始答案是关于MT 6的。
您需要使用
IReceiveEndpointObserver
示例,在配置端点时附加观察者:MT 8允许注册端点观察者
来自文档: