Partager via

EventProcessorClient.ClaimOwnershipAsync Méthode

  • Référence

Définition

Espace de noms:
Azure.Messaging.EventHubs
Assembly:
Azure.Messaging.EventHubs.Processor.dll
Paquet:
Azure.Messaging.EventHubs.Processor v5.11.3
Paquet:
Azure.Messaging.EventHubs.Processor v5.12.0-beta.1
Source:
EventProcessorClient.cs
Source:
EventProcessorClient.cs

Tente de revendiquer la propriété des partitions spécifiées pour traitement. Cette méthode est utilisée par l’équilibrage de charge pour permettre aux instances de processeur d’événements de répartir la responsabilité du traitement des partitions pour un hub d’événements donné et le jumelage de groupes de consommateurs entre les processeurs d’événements actifs.

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))

Paramètres

desiredOwnership
IEnumerable<EventProcessorPartitionOwnership>

Ensemble de la propriété de la partition souhaitée par le processeur d’événements instance ; il s’agit de l’ensemble de partitions qu’il tentera de demander la responsabilité du traitement.

cancellationToken
CancellationToken

Un CancellationToken instance pour signaler la demande d’annulation du traitement. Cela est le plus susceptible de se produire lorsque le processeur s’arrête.

Retours

Task<IEnumerable<EventProcessorPartitionOwnership>>

Ensemble d’enregistrements de propriété pour les partitions qui ont été correctement revendiquées ; il s’agit normalement du desiredOwnership ou d’un sous-ensemble de ces partitions.

S’applique à