EventProcessorClient.ClaimOwnershipAsync Methode

Definition

Namespace:

Azure.Messaging.EventHubs

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Paket:

Azure.Messaging.EventHubs.Processor v5.11.2

Quelle:

EventProcessorClient.cs

Versucht, den Besitz der angegebenen Partitionen für die Verarbeitung in Anspruch zu nehmen. Diese Methode wird vom Lastenausgleich verwendet, damit Ereignisprozessorinstanzen die Verantwortung für die Verarbeitung von Partitionen für einen bestimmten Event Hub und eine Consumergruppe auf die aktiven Ereignisprozessoren verteilen können.

protected override System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>> ClaimOwnershipAsync (System.Collections.Generic.IEnumerable<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> desiredOwnership, System.Threading.CancellationToken cancellationToken);

override this.ClaimOwnershipAsync : seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>

Protected Overrides Function ClaimOwnershipAsync (desiredOwnership As IEnumerable(Of EventProcessorPartitionOwnership), cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

Parameter

desiredOwnership

IEnumerable<EventProcessorPartitionOwnership>

Die vom Ereignisprozessor gewünschte Gruppe von Partitionsbesitz instance. Dies ist der Satz von Partitionen, die versucht, die Verantwortung für die Verarbeitung anzufordern.

cancellationToken

CancellationToken

Ein CancellationToken instance, um die Anforderung zum Abbrechen der Verarbeitung zu signalisieren. Dies tritt am wahrscheinlichsten auf, wenn der Prozessor heruntergefahren wird.

Gibt zurück

Task<IEnumerable<EventProcessorPartitionOwnership>>

Der Satz von Besitzerdatensätzen für die Partitionen, die erfolgreich beansprucht wurden; Dies wird erwartet, dass es sich um die desiredOwnership oder eine Teilmenge dieser Partitionen handelt.