Microsoft.Azure.EventHubs.Processor Namespace
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
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. |
Azure SDK for .NET