EventProcessor<TPartition>.OnPartitionProcessingStoppedAsync Método

Referência

Definição

Namespace:: Azure.Messaging.EventHubs.Primitives

Assembly:: Azure.Messaging.EventHubs.dll

Pacote:: Azure.Messaging.EventHubs v5.11.3

Pacote:: Azure.Messaging.EventHubs v5.12.0-beta.1

Origem:: EventProcessor.cs

Origem:: EventProcessor.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

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.

Aplica-se a

Partilhar via