EventProcessor<TPartition>.OnPartitionProcessingStoppedAsync Método

Definición

Espacio de nombres:

Azure.Messaging.EventHubs.Primitives

Ensamblado:

Azure.Messaging.EventHubs.dll

Paquete:

Azure.Messaging.EventHubs v5.11.3

Source:

EventProcessor.cs

Realiza las tareas necesarias cuando se detiene el procesamiento de una partición. Esto suele ocurrir cuando otra instancia del procesador de eventos reclama la partición o cuando se apaga la instancia del procesador de eventos actual.

protected virtual System.Threading.Tasks.Task OnPartitionProcessingStoppedAsync (TPartition partition, Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason reason, System.Threading.CancellationToken cancellationToken);

abstract member OnPartitionProcessingStoppedAsync : 'Partition * Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.OnPartitionProcessingStoppedAsync : 'Partition * Azure.Messaging.EventHubs.Processor.ProcessingStoppedReason * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Protected Overridable Function OnPartitionProcessingStoppedAsync (partition As TPartition, reason As ProcessingStoppedReason, cancellationToken As CancellationToken) As Task

Parámetros

partition

TPartition

Contexto de la partición para la que se detiene el procesamiento.

reason

ProcessingStoppedReason

Motivo por el que se detiene el procesamiento para la partición.

cancellationToken

CancellationToken

Instancia CancellationToken de para indicar la solicitud para cancelar el procesamiento. Esto no se espera que indique en circunstancias normales y solo se producirá si el procesador encuentra un error irrecuperable.

Devoluciones

Task

Comentarios

No se recomienda que el estado del procesador se administre directamente desde dentro de este método; solicitar iniciar o detener el procesador puede dar lugar a un escenario de interbloqueo, especialmente si se usa la forma sincrónica de la llamada.

Este método se invocará simultáneamente, ya que cada cierre es independiente. No se impone ningún límite de tiempo en una invocación; es seguro para que las implementaciones realicen operaciones de larga duración y reintentos según sea necesario. Este controlador no tiene ninguna influencia en el procesamiento de la partición asociada y no ofrece ninguna garantía de que la ejecución se complete antes de reiniciar el procesamiento de la partición o migrar a un nuevo host.