Partager via

EventProcessor<TPartition>.ClaimOwnershipAsync Méthode

  • Référence

Définition

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

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

protected abstract 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);
abstract member ClaimOwnershipAsync : seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership> * System.Threading.CancellationToken -> System.Threading.Tasks.Task<seq<Azure.Messaging.EventHubs.Primitives.EventProcessorPartitionOwnership>>
Protected MustOverride Function ClaimOwnershipAsync (desiredOwnership As IEnumerable(Of EventProcessorPartitionOwnership), cancellationToken As CancellationToken) As Task(Of IEnumerable(Of EventProcessorPartitionOwnership))

Paramètres

desiredOwnership
IEnumerable<EventProcessorPartitionOwnership>

Ensemble de propriété de partition souhaité 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 plus susceptible de se produire lorsque le processeur s’arrête.

Retours

Task<IEnumerable<EventProcessorPartitionOwnership>>

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

S’applique à