Partilhar via


Microsoft.Azure.EventHubs.Processor Namespace

Classes

Checkpoint

O objeto de contexto usado para preservar o estado no fluxo.

EventProcessorConfigurationException

Uma exceção que especifica que a EventProcessorHost configuração está incorreta.

EventProcessorHost

Representa um host para processar dados de evento dos Hubs de Eventos.

EventProcessorOptions

Define as opções de runtime ao registrar uma IEventProcessor interface com um EventHubConsumerGroup. Esse também é o mecanismo para capturar exceções de uma instância IEventProcessor usada por um EventProcessorHost objeto .

EventProcessorRuntimeException

Uma exceção gerada durante o processamento de eventos.

ExceptionReceivedEventArgs

Fornece dados para o evento de Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String) .

Lease

Contém informações de propriedade da partição.

LeaseLostException

Representa uma exceção que ocorre quando a concessão de serviço foi perdida.

PartitionContext

Encapsula informações relacionadas a uma partição de Hubs de Eventos usada pelo IEventProcessor.

PartitionManagerOptions

Opções para controlar vários aspectos da distribuição de partição que ocorrem dentro EventProcessorHost da instância.

Interfaces

ICheckpointManager

Se você quiser ter pontos de verificação do repositório EventProcessorHost em algum lugar diferente do Armazenamento do Azure, poderá escrever seu próprio gerenciador de ponto de verificação usando essa interface.

Os gerenciadores de Armazenamento do Azure usam o mesmo armazenamento para concessão e pontos de verificação, portanto, ambas as interfaces são implementadas pela mesma classe. Você estará livre para fazer a mesma coisa se tiver um repositório unificado para ambos os tipos de dados.

Essa interface não especifica métodos de inicialização porque não temos como saber quais informações sua implementação exigirá.

IEventProcessor

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.

IEventProcessorFactory

Interface que deve ser implementada por uma classe de fábrica do processador de eventos.

As fábricas fornecidas pelo usuário serão necessárias se a criação de um objeto de processador de eventos exigir mais trabalho do que apenas um novo com um construtor sem parâmetros.

ILeaseManager

Se você quiser ter concessões de repositório EventProcessorHost em algum lugar diferente do Armazenamento do Azure, poderá escrever seu próprio gerenciador de concessão usando essa interface.

Os gerenciadores de Armazenamento do Azure usam o mesmo armazenamento para concessão e pontos de verificação, portanto, ambas as interfaces são implementadas pela mesma classe. Você estará livre para fazer a mesma coisa se tiver um repositório unificado para ambos os tipos de dados.

Essa interface não especifica métodos de inicialização porque não temos como saber quais informações sua implementação exigirá.

Enumerações

CloseReason

Motivo para fechar um EventProcessorHost.