EventProcessor<TPartition>.OnPartitionProcessingStoppedAsync Método

Definição

Namespace:

Azure.Messaging.EventHubs.Primitives

Assembly:

Azure.Messaging.EventHubs.dll

Pacote:

Azure.Messaging.EventHubs v5.11.2

Origem:

EventProcessor.cs

Executa as tarefas necessárias ao processar uma partição que está sendo interrompida. Isso geralmente ocorre quando a partição é reivindicada por outra instância do processador de eventos ou quando a instância atual do processador de eventos está sendo fechada.

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

O contexto da partição para a qual o processamento está sendo interrompido.

reason

ProcessingStoppedReason

O motivo pelo qual o processamento está sendo interrompido para a partição.

cancellationToken

CancellationToken

Uma CancellationToken instância para sinalizar a solicitação para cancelar o processamento. Isso não é esperado para sinalizar em circunstâncias normais e só ocorrerá se o processador encontrar um erro irrecuperável.

Retornos

Task

Comentários

Não é recomendável que o estado do processador seja gerenciado diretamente nesse método; solicitar para iniciar ou parar o processador pode resultar em um cenário de deadlock, especialmente se estiver usando a forma síncrona da chamada.

Esse método será invocado simultaneamente, pois cada fechamento é independente. Nenhum limite de tempo é imposto a uma invocação; É seguro que as implementações executem operações de longa execução e novas tentativas conforme necessário. Esse manipulador não tem influência no processamento da partição associada e não oferece nenhuma garantia de que a execução será concluída antes que o processamento da partição seja reiniciado ou migre para um novo host.