PublishEndpoint.Publish 在 RabbitMQ 内存警报关闭时永远挂起

Question

我正在使用 MassTransit 和 RabbitMQ。当 RabbitMQ RAM 使用超过某个限制时，会引发 memory alarm。 在 RabbitMQ 管理网站的概述中，内存指示器变为红色并显示

The memory alarm for this node has gone off. It will block incoming network traffic until the memory usage drops below the watermark.

在此状态下，我的服务仍会尝试使用 MassTransit 发布消息。但是发布异步任务永远不会完成/永远等待继续。在我看来，MassTransit 发布中似乎缺少一些超时机制。如果在一定时间后无法发布消息，我希望有一个例外。我找不到配置超时行为的方法。

你是如何处理这种情况的？

谢谢

Answer 1

Publish 方法接受一个 CancellationToken，可用于取消发布。这是以前 的代码示例，其中包含如何指定超时的代码示例。