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

Question

在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秒.

Answer 1

你可能可以QueueClient.Abort这样使用：

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