EventProcessorOptions Klasse

Definition

Namespace:

Microsoft.Azure.EventHubs.Processor

Assembly:

Microsoft.Azure.EventHubs.Processor.dll

Paket:

Microsoft.Azure.EventHubs.Processor v4.3.2

Quelle:

EventProcessorOptions.cs

Definiert die Laufzeitoptionen beim Registrieren einer IEventProcessor Schnittstelle bei einer EventHubConsumerGroup. Dies ist auch der Mechanismus zum Abfangen von Ausnahmen von einer IEventProcessor-instance, die von einem EventProcessorHost -Objekt verwendet wird.

public sealed class EventProcessorOptions

type EventProcessorOptions = class

Public NotInheritable Class EventProcessorOptions

Vererbung

Object

EventProcessorOptions

Konstruktoren

EventProcessorOptions()

Erstellt ein neues EventProcessorOptions-Objekt.

Eigenschaften

DefaultOptions	Gibt einen EventProcessorOptions-instance zurück, bei dem alle Optionen auf die Standardwerte festgelegt sind. Die Standardwerte lauten wie folgt: MaxBatchSize: 10 ReceiveTimeOut: 1 Minute PrefetchCount: 300 InitialOffsetProvider: Verwendet den letzten Offset-Prüfpunkt oder StartOfStream. InvokeProcessorAfterReceiveTimeout: false
EnableReceiverRuntimeMetric	Ruft einen Wert ab, der angibt, ob die Laufzeitmetrik eines Empfängers aktiviert ist, oder legt den Wert fest.
InitialOffsetProvider	Ruft einen Delegaten ab, der zum Abrufen der Anfangsposition für eine bestimmte Partition zum Erstellen PartitionReceiververwendet wird, oder legt diesen fest. Delegate wird durch Übergeben von PartitionId aufgerufen, und der Benutzer kann zum Empfangen von Nachrichten zurückkehren PartitionReceiver . Dies wird nur verwendet, wenn für die zugeordnete Partition kein Prüfpunkt gefunden werden kann.
InvokeProcessorAfterReceiveTimeout	Gibt zurück, ob der EventProcessorHost IEventProcessor.OnEvents(null) aufruft, wenn ein Empfangstimeout auftritt (true) oder nicht (false).
MaxBatchSize	Gibt die maximale Größe eines Ereignisbatches zurück, mit dem IEventProcessor.ProcessEventsAsync aufgerufen wird.
PrefetchCount	Ruft die aktuelle Prefetchanzahl für den zugrunde liegenden Client ab oder legt diese fest. Der Standardwert ist 300.
ReceiveTimeout	Ruft die Timeoutlänge für Empfangsvorgänge ab oder legt diese fest.
WebProxy	Ruft den Webproxy ab oder legt den Webproxy fest. Ein Proxy ist nur anwendbar, wenn der Transporttyp auf AmqpWebSockets festgelegt ist.

Methoden

SetExceptionHandler(Action<ExceptionReceivedEventArgs>)

Legt einen Handler fest, der Benachrichtigungen über allgemeine Ausnahmen empfängt. Ausnahmen, die beim Verarbeiten von Ereignissen von einer bestimmten Event Hub-Partition auftreten, werden an die onError-Methode des Ereignisprozessors für diese Partition übermittelt. Dieser Handler wird in Fällen aufgerufen, in denen der Auslösenaktivität kein Ereignisprozessor zugeordnet ist oder der Ereignisprozessor nicht erstellt werden konnte.