当RabbitMQ关闭时,默认情况下(我认为(Masstransit尝试无限连接并得到"RabbitMQ连接失败:代理无法访问:guest@localhost:5672/"错误。
Masstransit 在 RabbitMQ 上线后立即开始工作。无论如何,我们可以对重试次数设置限制吗?因此,Masstransit 将停止重试连接 RabbitMQ。
要限制连接到 RabbitMQ 所花费的时间,请将CancellationToken
传递给StartAsync
方法。
using var source = new CancellationTokenSource(TimeSpan.FromSeconds(30));
await bus.StartAsync(source.Token);