IEventProcessor Interface

  • Referência

Definição

Namespace:
Microsoft.Azure.EventHubs.Processor
Assembly:
Microsoft.Azure.EventHubs.Processor.dll
Pacote:
Microsoft.Azure.EventHubs.Processor v4.3.2

Interface que deve ser implementada por classes de processador de eventos.

Qualquer instância específica de uma classe de processador de eventos processará apenas eventos de uma partição de um Hub de Eventos. Um PartitionContext é fornecido com cada chamada para o processador de eventos porque alguns parâmetros podem ser alterados, mas sempre será a mesma partição.

Embora EventProcessorHost seja multithreaded, as chamadas para uma determinada instância de uma classe de processador de eventos são serializadas, exceto onError(). OnOpen() é chamado primeiro, então OnEvents() será chamado de zero ou mais vezes. Quando o processador de eventos precisa ser desligado, seja porque houve uma falha em algum lugar ou a concessão da partição foi perdida ou porque todo o host do processador está sendo desligado, OnClose() é chamado após o retorno da última chamada OnEvents().

OnError() pode ser chamado enquanto OnEvents() ou OnClose() está em execução. Nenhuma sincronização é tentada para evitar possível deadlock.

public interface IEventProcessor
type IEventProcessor = interface
Public Interface IEventProcessor

Métodos

CloseAsync(PartitionContext, CloseReason)

Chamado pelo host do processador para indicar que o processador de eventos está sendo interrompido.
OpenAsync(PartitionContext)

Chamado pelo host do processador para inicializar o processador de eventos.
ProcessErrorAsync(PartitionContext, Exception)

Chamado quando o cliente subjacente experimenta um erro durante o recebimento. EventProcessorHost cuidará da recuperação do erro e continuará a bombear mensagens, portanto, nenhuma ação é necessária do seu código. Esse método é fornecido para fins informativos.
ProcessEventsAsync(PartitionContext, IEnumerable<EventData>)

Chamado pelo host do processador quando um lote de eventos chegou.

É aqui que o trabalho real do processador de eventos é feito.

Aplica-se a