EventProcessor<TPartition>.OnInitializingPartitionAsync 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 para inicializar uma partição e seu contexto associado para processamento de eventos.

protected virtual System.Threading.Tasks.Task OnInitializingPartitionAsync (TPartition partition, System.Threading.CancellationToken cancellationToken);

abstract member OnInitializingPartitionAsync : 'Partition * System.Threading.CancellationToken -> System.Threading.Tasks.Task
override this.OnInitializingPartitionAsync : 'Partition * System.Threading.CancellationToken -> System.Threading.Tasks.Task

Protected Overridable Function OnInitializingPartitionAsync (partition As TPartition, cancellationToken As CancellationToken) As Task

Parâmetros

partition

TPartition

O contexto da partição que está sendo inicializada. Somente os membros conhecidos do EventProcessorPartition serão preenchidos. Se um contexto personalizado estiver sendo usado, o implementador desse método será responsável por inicializar membros personalizados.

cancellationToken

CancellationToken

Uma CancellationToken instância para sinalizar a solicitação para cancelar a inicialização. Isso provavelmente ocorrerá se a partição for reivindicada por outra instância do processador de eventos ou se o processador estiver sendo desligado.

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, limitado a uma chamada por partição. O processador aguardará cada invocação antes de começar a processar a partição associada.

O processador aguardará indefinidamente a conclusão da execução do manipulador. É recomendável que as implementações evitem operações de execução prolongada, pois atrasarão o processamento da partição associada.