Partager via

BlobCheckpointStore.ClaimOwnershipAsync Méthode

  • Référence

Définition

Espace de noms:
Azure.Messaging.EventHubs.Primitives
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:
BlobCheckpointStore.cs
Source:
BlobCheckpointStore.cs

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

public 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>>
Public 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 à