EventProcessor<TPartition>.ClaimOwnershipAsync Método

  • Referencia

Definición

Espacio de nombres:
Azure.Messaging.EventHubs.Primitives
Ensamblado:
Azure.Messaging.EventHubs.dll
Paquete:
Azure.Messaging.EventHubs v5.11.3
Paquete:
Azure.Messaging.EventHubs v5.12.0-beta.1
Source:
EventProcessor.cs
Source:
EventProcessor.cs

Intenta reclamar la propiedad de las particiones especificadas para su procesamiento. Esta operación se usa mediante el equilibrio de carga para permitir la distribución de la responsabilidad de procesar particiones para un centro de eventos y un emparejamiento de grupos de consumidores entre los procesadores de eventos activos.

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

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.

Se aplica a