c# - 如何在Azure Service Bus Queue客户端中使用CancellationToken？

在Azure Service Bus队列客户端中，我使用 ReceiveBatchAsync 方法等待指定的时间以异步接收一批消息。

var messages = await queueClient.ReceiveBatchAsync(10, TimeSpan.FromSeconds(30));

我想彻底关闭我的应用程序，所以我要在所有长时间运行的异步进程上实现CancellationToken，但是ReceiveBatchAsync似乎并没有可取消的重载。

换句话说，我想这样做，但是我不能:

var messages = await queueClient.ReceiveBatchAsync(10, TimeSpan.FromSeconds(30),
                                                       cancellationToken);

将CancellationToken应用于不直接提供它的任务的最佳方法是什么？我不想在关机期间等待整个30秒。

最佳答案

您可能可以这样使用 QueueClient.Abort :

using (cancellationToken.Register(() => queueClient.Abort())
{
    var messages = await queueClient.ReceiveBatchAsync(
        10, TimeSpan.FromSeconds(30));
    return messages; // or process it
}

关于c# - 如何在Azure Service Bus Queue客户端中使用CancellationToken？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/23668655/