你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

QueueProcessor 类

定义

此类定义用于处理队列消息的策略。

public class QueueProcessor
type QueueProcessor = class
Public Class QueueProcessor
继承
QueueProcessor

注解

可以通过实现自定义 QueueProcessor 来注册自定义 IQueueProcessorFactory实现。

构造函数

QueueProcessor(QueueProcessorOptions)

构造一个新实例。

方法

BeginProcessingMessageAsync(QueueMessage, CancellationToken)

当有新消息要处理时,在调用作业函数之前调用此方法。 这允许在处理开始之前对消息进行任何预处理。

CompleteProcessingMessageAsync(QueueMessage, FunctionResult, CancellationToken)

此方法在调用作业函数后完成对指定消息的处理。

CopyMessageToPoisonQueueAsync(QueueMessage, QueueClient, CancellationToken)

将指定的消息移动到病毒队列。

DeleteMessageAsync(QueueMessage, CancellationToken)

删除指定的消息。

OnMessageAddedToPoisonQueueAsync(PoisonMessageEventArgs)

调用以引发 MessageAddedToPoisonQueue 事件。

ReleaseMessageAsync(QueueMessage, FunctionResult, TimeSpan, CancellationToken)

将指定的失败消息释放回队列。

事件

MessageAddedToPoisonQueueAsync

将消息添加到有害队列时引发的事件。

适用于