QueueProcessor Classe

Définition

Espace de noms:

Microsoft.Azure.WebJobs.Host.Queues

Assembly:

Microsoft.Azure.WebJobs.Extensions.Storage.Queues.dll

Paquet:

Microsoft.Azure.WebJobs.Extensions.Storage.Queues v5.3.4

Source:

QueueProcessor.cs

Cette classe définit une stratégie utilisée pour le traitement des messages de file d’attente.

public class QueueProcessor

type QueueProcessor = class

Public Class QueueProcessor

Héritage

Object

QueueProcessor

Remarques

Les implémentations personnalisées QueueProcessor peuvent être inscrites en implémentant un personnalisé IQueueProcessorFactory.

Constructeurs

QueueProcessor(QueueProcessorOptions)

Construit une nouvelle instance.

Méthodes

BeginProcessingMessageAsync(QueueMessage, CancellationToken)	Cette méthode est appelée lorsqu’un nouveau message est à traiter, avant que la fonction de travail soit appelée. Cela permet à n’importe quel prétraitement d’avoir lieu sur le message avant le début du traitement.
CompleteProcessingMessageAsync(QueueMessage, FunctionResult, CancellationToken)	Cette méthode termine le traitement du message spécifié, une fois que la fonction de travail a été appelée.
CopyMessageToPoisonQueueAsync(QueueMessage, QueueClient, CancellationToken)	Déplace le message spécifié vers la file d’attente de poison.
DeleteMessageAsync(QueueMessage, CancellationToken)	Supprimez le message spécifié.
OnMessageAddedToPoisonQueueAsync(PoisonMessageEventArgs)	Appelé pour déclencher l’événement MessageAddedToPoisonQueue.
ReleaseMessageAsync(QueueMessage, FunctionResult, TimeSpan, CancellationToken)	Relâchez le message d’échec spécifié dans la file d’attente.

Événements

MessageAddedToPoisonQueueAsync

Événement déclenché lorsqu’un message est ajouté à la file d’attente de poison.