Partager via


EventProcessorOptions Classe

Définition

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 .

public sealed class EventProcessorOptions
type EventProcessorOptions = class
Public NotInheritable Class EventProcessorOptions
Héritage
EventProcessorOptions

Constructeurs

EventProcessorOptions()

Crée un objet EventProcessorOptions.

Propriétés

DefaultOptions

Retourne une instance EventProcessorOptions avec toutes les options définies sur les valeurs par défaut. Les valeurs par défaut sont :

MaxBatchSize : 10

ReceiveTimeOut : 1 minute

PrefetchCount: 300

InitialOffsetProvider : utilise le dernier décalage avec point de contrôle ou StartOfStream

InvokeProcessorAfterReceiveTimeout : false

EnableReceiverRuntimeMetric

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

InitialOffsetProvider

Obtient ou définit un délégué qui est utilisé pour obtenir la position initiale d’une partition donnée pour créer PartitionReceiver. Le délégué est appelé en transmettant PartitionId, puis l’utilisateur peut revenir PartitionReceiver pour recevoir des messages. Il est utilisé uniquement lorsqu’un point de contrôle est introuvable pour la partition associée.

InvokeProcessorAfterReceiveTimeout

Retourne si EventProcessorHost appelle IEventProcessor.OnEvents(null) quand un délai d’expiration de réception se produit (true) ou non (false).

MaxBatchSize

Retourne la taille maximale d’un lot d’événements avec lequel IEventProcessor.ProcessEventsAsync sera appelé

PrefetchCount

Obtient ou définit le nombre actuel de prérécupérations pour le client sous-jacent. La valeur par défaut est 300.

ReceiveTimeout

Obtient ou définit la durée du délai d’attente pour les opérations de réception.

WebProxy

Obtient ou définit le proxy web. Un proxy s’applique uniquement lorsque le type de transport est défini sur AmqpWebSockets.

Méthodes

SetExceptionHandler(Action<ExceptionReceivedEventArgs>)

Définit un gestionnaire qui reçoit la notification des exceptions générales.

Les exceptions qui se produisent lors du traitement des événements d’une partition Event Hub particulière sont remises à la méthode onError du processeur d’événements pour cette partition. Ce gestionnaire est appelé dans les cas où aucun processeur d’événements n’est associé à l’activité de levée, ou lorsque le processeur d’événements n’a pas pu être créé.

S’applique à