QueueProcessor Classe

Definição

Namespace:

Microsoft.Azure.WebJobs.Host.Queues

Assembly:

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

Pacote:

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

Origem:

QueueProcessor.cs

Essa classe define uma estratégia usada para processar mensagens de fila.

public class QueueProcessor

type QueueProcessor = class

Public Class QueueProcessor

Herança

Object

QueueProcessor

Comentários

Implementações personalizadas QueueProcessor podem ser registradas implementando um personalizado IQueueProcessorFactory.

Construtores

QueueProcessor(QueueProcessorOptions)

Constrói uma nova instância.

Métodos

BeginProcessingMessageAsync(QueueMessage, CancellationToken)	Esse método é chamado quando há uma nova mensagem a ser processada, antes que a função de trabalho seja invocada. Isso permite que qualquer pré-processamento ocorra na mensagem antes do início do processamento.
CompleteProcessingMessageAsync(QueueMessage, FunctionResult, CancellationToken)	Esse método conclui o processamento da mensagem especificada depois que a função de trabalho é invocada.
CopyMessageToPoisonQueueAsync(QueueMessage, QueueClient, CancellationToken)	Move a mensagem especificada para a fila suspeita.
DeleteMessageAsync(QueueMessage, CancellationToken)	Exclua a mensagem especificada.
OnMessageAddedToPoisonQueueAsync(PoisonMessageEventArgs)	Chamado para acionar o evento MessageAddedToPoisonQueue.
ReleaseMessageAsync(QueueMessage, FunctionResult, TimeSpan, CancellationToken)	Libere a mensagem com falha especificada de volta para a fila.

Eventos

MessageAddedToPoisonQueueAsync

Evento gerado quando uma mensagem é adicionada à fila suspeita.