Microsoft.Azure.EventHubs.Processor Espace de noms

Classes

Checkpoint

Objet de contexte utilisé pour conserver l’état dans le flux.

EventProcessorConfigurationException

Exception qui spécifie que la EventProcessorHost configuration est incorrecte.

EventProcessorHost

Représente un hôte pour le traitement des données d’événement Event Hubs.

EventProcessorOptions

Définit les options d’exécution lors de l’inscription d’une IEventProcessor interface auprès d’un EventHubConsumerGroup. Il s’agit également du mécanisme permettant d’intercepter les exceptions d’un instance IEventProcessor utilisé par un EventProcessorHost objet.

EventProcessorRuntimeException

Exception levée pendant le traitement des événements.

ExceptionReceivedEventArgs

Fournit des données pour l'événement Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String).

Lease

Contient des informations sur la propriété de la partition.

LeaseLostException

Représente une exception qui se produit lorsque le bail de service a été perdu.

PartitionContext

Encapsule les informations relatives à une partition Event Hubs utilisée par IEventProcessor.

PartitionManagerOptions

Options permettant de contrôler différents aspects de la distribution de partition au sein EventProcessorHost de instance.

Interfaces

ICheckpointManager

Si vous souhaitez avoir des points de contrôle de magasin EventProcessorHost ailleurs que stockage Azure, vous pouvez écrire votre propre gestionnaire de points de contrôle à l’aide de cette interface.

Les responsables stockage Azure utilisent le même stockage pour les baux et les points de contrôle, de sorte que les deux interfaces sont implémentées par la même classe. Vous êtes libre de faire la même chose si vous disposez d’un magasin unifié pour les deux types de données.

Cette interface ne spécifie pas les méthodes d’initialisation, car nous n’avons aucun moyen de savoir quelles informations votre implémentation aura besoin.

IEventProcessor

Interface qui doit être implémentée par les classes de processeur d’événements.

Toute instance donnée d’une classe de processeur d’événements traite uniquement les événements d’une partition d’un hub d’événements. Un PartitionContext est fourni avec chaque appel au processeur d’événements, car certains paramètres peuvent changer, mais il s’agit toujours de la même partition.

Bien qu’EventProcessorHost soit multithread, les appels à un instance donné d’une classe de processeur d’événements sont sérialisés, à l’exception de OnError(). OnOpen() est appelé en premier, puis OnEvents() est appelé zéro ou plusieurs fois. Lorsque le processeur d’événements doit être arrêté, que ce soit en raison d’un échec quelque part, ou parce que le bail de la partition a été perdu, ou parce que l’hôte du processeur entier est en cours d’arrêt, OnClose() est appelé après le retour du dernier appel OnEvents().

OnError() peut être appelé pendant que OnEvents() ou OnClose() s’exécute. Aucune synchronisation n’est tentée afin d’éviter un blocage éventuel.

IEventProcessorFactory

Interface qui doit être implémentée par une classe de fabrique du processeur d’événements.

Des fabriques fournies par l’utilisateur sont nécessaires si la création d’un objet de processeur d’événements nécessite plus de travail qu’un simple nouveau avec un constructeur sans paramètre.

ILeaseManager

Si vous souhaitez avoir des baux de magasin EventProcessorHost ailleurs que stockage Azure, vous pouvez écrire votre propre gestionnaire de bail à l’aide de cette interface.

Les responsables stockage Azure utilisent le même stockage pour les baux et les points de contrôle, de sorte que les deux interfaces sont implémentées par la même classe. Vous êtes libre de faire la même chose si vous disposez d’un magasin unifié pour les deux types de données.

Cette interface ne spécifie pas les méthodes d’initialisation, car nous n’avons aucun moyen de savoir quelles informations votre implémentation aura besoin.

Énumérations

CloseReason

Raison de la fermeture d’un EventProcessorHost.