次の方法で共有


QueueProcessor クラス

定義

このクラスは、キュー メッセージの処理に使用される戦略を定義します。

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

注釈

カスタム実装は、カスタム QueueProcessorIQueueProcessorFactoryを実装することで登録できます。

コンストラクター

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

有害キューにメッセージが追加されたときに発生するイベント。

適用対象