EventProcessorClient.ClaimOwnershipAsync Método

Definición

Espacio de nombres:

Azure.Messaging.EventHubs

Ensamblado:

Azure.Messaging.EventHubs.Processor.dll

Paquete:

Azure.Messaging.EventHubs.Processor v5.11.3

Source:

EventProcessorClient.cs

Intenta reclamar la propiedad de las particiones especificadas para su procesamiento. Este método se usa mediante el equilibrio de carga para permitir que las instancias del procesador de eventos distribuyan la responsabilidad de procesar las particiones de un centro de eventos determinado y el emparejamiento de grupos de consumidores entre los procesadores de eventos activos.

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

Parámetros

desiredOwnership

IEnumerable<EventProcessorPartitionOwnership>

Conjunto de propiedad de partición deseada por la instancia del procesador de eventos; este es el conjunto de particiones que intentará solicitar la responsabilidad del procesamiento.

cancellationToken

CancellationToken

Instancia CancellationToken de para indicar la solicitud para cancelar el procesamiento. Esto es lo más probable que se produzca cuando el procesador se apague.

Devoluciones

Task<IEnumerable<EventProcessorPartitionOwnership>>

Conjunto de registros de propiedad para las particiones que se reclamaron correctamente; se espera que sea el desiredOwnership subconjunto o de esas particiones.