在公共交通中指定发布超时

问题描述

使用MassTransit库发布消息时，是否可以指定超时值.消息代理发生故障时如何处理方案.现在看来，发布调用会无限期地等待.控制这些行为将是很好的.我们应该依靠取消令牌吗?实施超时可能会更好.

Is there a way to specify timeout value when publishing messages using the MassTransit Library. How to handle scenarios when message broker goes down. Now it seems that Publish call waits indefinitely. It would be nice to control these behavior. Should we rely on cancellation token? Timeout implementation might be better.

推荐答案

您可以将 CancellationToken 传递给 Publish .如果取消，将抛出 OperationCanceledException.如果要使用超时，则可以创建具有超时的 CancellationTokenSource .

You can pass a CancellationToken to Publish. If canceled, an OperationCanceledException will be thrown. If you want to use a timeout, you can create a CancellationTokenSource with a timeout.

using var source = new CancellationTokenSource(TimeSpan.FromSeconds(30));

await bus.Publish(message, source.Token);

这篇关于在公共交通中指定发布超时的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！