EventProcessorClient.ProcessEventAsync Evento

Definição

Namespace:

Azure.Messaging.EventHubs

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Pacote:

Azure.Messaging.EventHubs.Processor v5.11.2

Origem:

EventProcessorClient.cs

Executa as tarefas necessárias para processar um lote de eventos para uma determinada partição conforme eles são lidos do serviço hubs de eventos. A implementação é obrigatória.

Se ocorrer uma exceção dentro do código para esse método, o processador de eventos permitirá que ele propague a pilha sem tentar manirá-la de forma alguma. Na maioria dos hosts, isso falhará na tarefa responsável pelo processamento de partição, fazendo com que ela seja reiniciada do último ponto de verificação. Em alguns hosts, ele pode travar o processo. Os desenvolvedores são fortemente incentivados a levar em conta todos os cenários de exceção e se proteger contra eles usando blocos try/catch e outros meios conforme apropriado.

Não é recomendável que o estado do processador seja gerenciado diretamente nesse manipulador; a solicitação para iniciar ou parar o processador pode resultar em um cenário de deadlock, especialmente se estiver usando a forma síncrona da chamada.

public event Func<Azure.Messaging.EventHubs.Processor.ProcessEventArgs,System.Threading.Tasks.Task> ProcessEventAsync;

member this.ProcessEventAsync : Func<Azure.Messaging.EventHubs.Processor.ProcessEventArgs, System.Threading.Tasks.Task> 

Public Custom Event ProcessEventAsync As Func(Of ProcessEventArgs, Task) 

Tipo de evento

Func<ProcessEventArgs,Task>

Exceções

ArgumentException

Se for feita uma tentativa de remover um manipulador que não corresponde ao manipulador atual registrado.

NotSupportedException

Se for feita uma tentativa de adicionar um manipulador quando um estiver registrado no momento.

Comentários

Esse manipulador será invocado simultaneamente, limitado a uma chamada por partição. O processador aguardará cada invocação para garantir que os eventos da mesma partição sejam processados uma vez na ordem em que foram lidos da partição.

Nenhum limite de tempo é imposto a uma invocação desse manipulador; o processador aguardará indefinidamente a conclusão da execução antes de expedir outro evento para a partição associada. É seguro que as implementações executem operações de execução prolongada, repetições, atrasos e atividades de mensagens mortas.

Confira também

• OnProcessingEventBatchAsync(IEnumerable<EventData>, EventProcessorPartition, CancellationToken)