EventProcessorHost Classe

Referência

Definição

Namespace:: Microsoft.ServiceBus.Messaging

Assembly:: Microsoft.ServiceBus.Messaging.EventProcessorHost.dll

Pacote:: Microsoft.Azure.ServiceBus.EventProcessorHost v5.0.1

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.

Um host muito simples para processar mensagens do EventHub. Ele cuida da distribuição de partições do EventHub entre instâncias EventProcessorHost. Ele cria um Blob de Blocos do Azure para cada partição no EventHub e usa esses blobs para gerenciar a concessão de uma partição. Cada instância eventProcessorHost está executando as duas seguintes tarefas: 1) Renovar Concessões: ele mantém o controle das concessões atualmente pertencentes ao host e continua renovando as concessões. 2) Adquirir Concessões: cada instância sonda continuamente todos os blobs de concessão para marcar se houver concessões que ela deve adquirir para que o sistema entre em estado equilibrado. O aplicativo cliente precisa implementar IEventProcessor e registrar a implementação do processador com EventProcessorHost.

public class EventProcessorHost : IDisposable

type EventProcessorHost = class
    interface IDisposable

Public Class EventProcessorHost
Implements IDisposable

Herança: Object
EventProcessorHost

Implementações: IDisposable

Construtores

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)	Cria uma nova instância de EventProcessorHost.
EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)	Cria uma nova instância de EventProcessorHost.
EventProcessorHost(String, String, String, String)	Cria uma nova instância de EventProcessorHost.
EventProcessorHost(String, String, String, String, String)	Inicializa uma nova instância da classe EventProcessorHost.
EventProcessorHost(String, String, String, String, String, String, String)	Inicializa uma nova instância da classe EventProcessorHost.

Propriedades

HostName	Obtém o nome do host, que é um nome exclusivo para a EventProcessorHost instância.
PartitionManagerOptions	Obtém ou define a PartitionManagerOptions instância usada pelo EventProcessorHost objeto .

Métodos

Dispose()	Um host muito simples para processar mensagens do EventHub. Ele cuida da distribuição de partições do EventHub entre instâncias EventProcessorHost. Ele cria um Blob de Blocos do Azure para cada partição no EventHub e usa esses blobs para gerenciar a concessão de uma partição. Cada instância eventProcessorHost está executando as duas seguintes tarefas: 1) Renovar Concessões: ele mantém o controle das concessões atualmente pertencentes ao host e continua renovando as concessões. 2) Adquirir Concessões: cada instância sonda continuamente todos os blobs de concessão para marcar se houver concessões que ela deve adquirir para que o sistema entre em estado equilibrado. O aplicativo cliente precisa implementar IEventProcessor e registrar a implementação do processador com EventProcessorHost.
Dispose(Boolean)	Um host muito simples para processar mensagens do EventHub. Ele cuida da distribuição de partições do EventHub entre instâncias EventProcessorHost. Ele cria um Blob de Blocos do Azure para cada partição no EventHub e usa esses blobs para gerenciar a concessão de uma partição. Cada instância eventProcessorHost está executando as duas seguintes tarefas: 1) Renovar Concessões: ele mantém o controle das concessões atualmente pertencentes ao host e continua renovando as concessões. 2) Adquirir Concessões: cada instância sonda continuamente todos os blobs de concessão para marcar se houver concessões que ela deve adquirir para que o sistema entre em estado equilibrado. O aplicativo cliente precisa implementar IEventProcessor e registrar a implementação do processador com EventProcessorHost.
RegisterEventProcessorAsync<T>()	Registra de forma assíncrona a implementação da IEventProcessor interface com o host usando a DefaultEventProcessorFactory<T> fábrica. Esse método também inicia o host e permite que ele comece a participar do processo de distribuição de partição.
RegisterEventProcessorAsync<T>(EventProcessorOptions)	Isso registra a IEventProcessor implementação com o host usando DefaultEventProcessorFactory<T>. Isso também inicia o host e faz com que ele comece a participar do processo de distribuição de partição.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	Isso registra IEventProcessorFactory a implementação com o host que é usado para criar uma instância do IEventProcessor quando ele assume a propriedade de uma partição. Isso também inicia o host e faz com que ele comece a participar do processo de distribuição de partição.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	Isso registra IEventProcessorFactory a implementação com o host que é usado para criar uma instância do IEventProcessor quando ele assume a propriedade de uma partição. Isso também inicia o host e faz com que ele comece a participar do processo de distribuição de partição.
ResetAllConnections()	Redefina todas as conexões receptoras dos Hubs de Eventos usadas por esta instância do EventProcessorHost.
ResetConnection(String)	Um host muito simples para processar mensagens do EventHub. Ele cuida da distribuição de partições do EventHub entre instâncias EventProcessorHost. Ele cria um Blob de Blocos do Azure para cada partição no EventHub e usa esses blobs para gerenciar a concessão de uma partição. Cada instância eventProcessorHost está executando as duas seguintes tarefas: 1) Renovar Concessões: ele mantém o controle das concessões atualmente pertencentes ao host e continua renovando as concessões. 2) Adquirir Concessões: cada instância sonda continuamente todos os blobs de concessão para marcar se houver concessões que ela deve adquirir para que o sistema entre em estado equilibrado. O aplicativo cliente precisa implementar IEventProcessor e registrar a implementação do processador com EventProcessorHost.
UnregisterEventProcessorAsync()	Desliga a instância de forma assíncrona EventProcessorHost . Esse método mantém as concessões em todas as partições atualmente mantidas e permite que cada IEventProcessor instância seja desligada corretamente invocando o CloseAsync(PartitionContext, CloseReason) método com um Shutdown objeto após a execução atual de ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) concluída.

Aplica-se a

Compartilhar via