BlobCheckpointStore.ClaimOwnershipAsync Método

Definição

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.Processor.dll

Pacote:

Azure.Messaging.EventHubs.Processor v5.11.3

Origem:

BlobCheckpointStore.cs

Tenta reivindicar a propriedade das partições especificadas para processamento. Essa operação é usada pelo balanceamento de carga para habilitar a distribuição da responsabilidade pelo processamento de partições para um Hub de Eventos e emparelhamento de grupo de consumidores entre os processadores de eventos ativos.

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

Parâmetros

desiredOwnership

IEnumerable<EventProcessorPartitionOwnership>

O conjunto de propriedade de partição desejado pela instância do processador de eventos; esse é o conjunto de partições que tentará solicitar a responsabilidade pelo processamento.

cancellationToken

CancellationToken

Uma CancellationToken instância para sinalizar a solicitação para cancelar o processamento. É mais provável que isso ocorra quando o processador está sendo desligado.

Retornos

Task<IEnumerable<EventProcessorPartitionOwnership>>

O conjunto de registros de propriedade para as partições que foram reivindicadas com êxito; espera-se que esse seja o desiredOwnership ou um subconjunto dessas partições.