EventProcessorOptions Classe

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

Obtient les options par défaut, qui sont 10 pour le MaxBatchSize, et 1 minute pour la ReceiveTimeOut propriété .

Obtient ou définit une valeur indiquant si la métrique d’exécution d’un récepteur est activée.

Obtient ou définit un délégué qui est utilisé pour obtenir le décalage initial d’une partition donnée pour créer EventHubReceiver. Le délégué est appelé en transmettant PartitionId, puis l’utilisateur peut retourner le décalage de départ sous forme de chaîne ou l’heure UTC de début pour la réception des messages. Ce n’est utilisé que lorsque Offset n’est pas fourni et que le récepteur est en cours de création pour la toute première fois. Cela correspond à CreateReceiverAsync(String, ReceiverOptions) ou CreateReceiverAsync(String, DateTime, ReceiverOptions) en fonction du type de valeur de retour du délégué.

L’activation de cette option entraîne ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) l’appel après chaque receiveTimeout lorsqu’il n’y a plus de messages dans le flux pour une partition.

Obtient ou définit le nombre maximal d’événements qu’un utilisateur est prêt à accepter pour le traitement par boucle de réception. Ce nombre est sur un niveau de partition par Event Hub.

Obtient ou définit le nombre d’événements que tout récepteur de la partition actuellement détenue met en cache activement. La valeur par défaut de cette propriété est 300.

Obtient ou définit l’intervalle de temps dans lequel l’utilisateur est prêt à attendre lorsque le processeur d’événements effectue une opération de réception.

Cet événement se déclenche chaque fois qu’une exception est rencontrée lors du traitement des événements. L’utilisateur peut inscrire un gestionnaire à cet événement pour obtenir une notification d’exception.