你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
QueueProcessor 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
此类定义用于处理队列消息的策略。
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 |
将消息添加到有害队列时引发的事件。 |