Partager via

IEventProcessor Interface

  • Référence

Définition

Espace de noms:
Microsoft.Azure.EventHubs.Processor
Assembly:
Microsoft.Azure.EventHubs.Processor.dll
Paquet:
Microsoft.Azure.EventHubs.Processor v4.3.2

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.

public interface IEventProcessor
type IEventProcessor = interface
Public Interface IEventProcessor

Méthodes

CloseAsync(PartitionContext, CloseReason)

Appelé par l’hôte du processeur pour indiquer que le processeur d’événements est en cours d’arrêt.
OpenAsync(PartitionContext)

Appelé par l’hôte du processeur pour initialiser le processeur d’événements.
ProcessErrorAsync(PartitionContext, Exception)

Appelé lorsque le client sous-jacent rencontre une erreur lors de la réception. EventProcessorHost s’occupe de récupérer après l’erreur et de continuer à pomper les messages, donc aucune action n’est nécessaire à partir de votre code. Cette méthode est fournie à des fins d’information.
ProcessEventsAsync(PartitionContext, IEnumerable<EventData>)

Appelé par l’hôte du processeur lorsqu’un lot d’événements est arrivé.

C’est là que le travail réel du processeur d’événements est effectué.

S’applique à