EventProcessorHost Classe

Définition

Espace de noms:

Microsoft.ServiceBus.Messaging

Assembly:

Microsoft.ServiceBus.Messaging.EventProcessorHost.dll

Paquet:

Microsoft.Azure.ServiceBus.EventProcessorHost v5.0.1

Hôte très simple pour le traitement des messages EventHub. Il s’occupe de distribuer les partitions EventHub entre les instances EventProcessorHost. Il crée un objet blob de blocs Azure pour chaque partition dans EventHub et utilise ces objets blob pour gérer le bail d’une partition. Chaque instance EventProcessorHost effectue les deux tâches suivantes : 1) Renouveler les baux : Il effectue le suivi des baux actuellement détenus par l’hôte et continue de renouveler les baux en continu. 2) Acquérir des baux : chaque instance interroge continuellement tous les objets blob de bail pour case activée s’il existe des baux qu’il doit acquérir pour que le système passe à un état équilibré. L’application cliente doit implémenter IEventProcessor et inscrire l’implémentation du processeur auprès d’EventProcessorHost.

public class EventProcessorHost : IDisposable

type EventProcessorHost = class
    interface IDisposable

Public Class EventProcessorHost
Implements IDisposable

Héritage

Object

EventProcessorHost

Implémente

IDisposable

Constructeurs

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)	Crée des instance d’EventProcessorHost.
EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)	Crée des instance d’EventProcessorHost.
EventProcessorHost(String, String, String, String)	Crée des instance d’EventProcessorHost.
EventProcessorHost(String, String, String, String, String)	Initialise une nouvelle instance de la classe EventProcessorHost.
EventProcessorHost(String, String, String, String, String, String, String)	Initialise une nouvelle instance de la classe EventProcessorHost.

Propriétés

HostName	Obtient le nom d’hôte, qui est un nom unique pour le EventProcessorHost instance.
PartitionManagerOptions	Obtient ou définit le PartitionManagerOptions instance utilisé par l’objet EventProcessorHost .

Méthodes

Dispose()	Hôte très simple pour le traitement des messages EventHub. Il s’occupe de distribuer les partitions EventHub entre les instances EventProcessorHost. Il crée un objet blob de blocs Azure pour chaque partition dans EventHub et utilise ces objets blob pour gérer le bail d’une partition. Chaque instance EventProcessorHost effectue les deux tâches suivantes : 1) Renouveler les baux : Il effectue le suivi des baux actuellement détenus par l’hôte et continue de renouveler les baux en continu. 2) Acquérir des baux : chaque instance interroge continuellement tous les objets blob de bail pour case activée s’il existe des baux qu’il doit acquérir pour que le système passe à un état équilibré. L’application cliente doit implémenter IEventProcessor et inscrire l’implémentation du processeur auprès d’EventProcessorHost.
Dispose(Boolean)	Hôte très simple pour le traitement des messages EventHub. Il s’occupe de distribuer les partitions EventHub entre les instances EventProcessorHost. Il crée un objet blob de blocs Azure pour chaque partition dans EventHub et utilise ces objets blob pour gérer le bail d’une partition. Chaque instance EventProcessorHost effectue les deux tâches suivantes : 1) Renouveler les baux : Il effectue le suivi des baux actuellement détenus par l’hôte et continue de renouveler les baux en continu. 2) Acquérir des baux : chaque instance interroge continuellement tous les objets blob de bail pour case activée s’il existe des baux qu’il doit acquérir pour que le système passe à un état équilibré. L’application cliente doit implémenter IEventProcessor et inscrire l’implémentation du processeur auprès d’EventProcessorHost.
RegisterEventProcessorAsync<T>()	Inscrit de manière asynchrone l’implémentation de l’interface IEventProcessor auprès de l’hôte à l’aide de la DefaultEventProcessorFactory<T> fabrique. Cette méthode démarre également l’hôte et lui permet de commencer à participer au processus de distribution de partition.
RegisterEventProcessorAsync<T>(EventProcessorOptions)	Cette opération inscrit IEventProcessor l’implémentation auprès de l’hôte à l’aide de DefaultEventProcessorFactory<T>. Cela démarre également l’hôte et l’amène à participer au processus de distribution de partition.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	Cela inscrit IEventProcessorFactory l’implémentation avec l’hôte qui est utilisé pour créer un instance de IEventProcessor quand il prend la propriété d’une partition. Cela démarre également l’hôte et l’amène à participer au processus de distribution de partition.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	Cela inscrit IEventProcessorFactory l’implémentation avec l’hôte qui est utilisé pour créer un instance de IEventProcessor quand il prend la propriété d’une partition. Cela démarre également l’hôte et l’amène à participer au processus de distribution de partition.
ResetAllConnections()	Réinitialisez toutes les connexions de récepteur Event Hubs utilisées par cette instance d’EventProcessorHost.
ResetConnection(String)	Hôte très simple pour le traitement des messages EventHub. Il s’occupe de distribuer les partitions EventHub entre les instances EventProcessorHost. Il crée un objet blob de blocs Azure pour chaque partition dans EventHub et utilise ces objets blob pour gérer le bail d’une partition. Chaque instance EventProcessorHost effectue les deux tâches suivantes : 1) Renouveler les baux : Il effectue le suivi des baux actuellement détenus par l’hôte et continue de renouveler les baux en continu. 2) Acquérir des baux : chaque instance interroge continuellement tous les objets blob de bail pour case activée s’il existe des baux qu’il doit acquérir pour que le système passe à un état équilibré. L’application cliente doit implémenter IEventProcessor et inscrire l’implémentation du processeur auprès d’EventProcessorHost.
UnregisterEventProcessorAsync()	Arrête de façon asynchrone le EventProcessorHost instance. Cette méthode conserve les baux sur toutes les partitions actuellement détenues et permet à chaque IEventProcessor instance de s’arrêter proprement en appelant la méthode avec un Shutdown objet une fois l’exécution CloseAsync(PartitionContext, CloseReason) actuelle terminéeProcessEventsAsync(PartitionContext, IEnumerable<EventData>).