EventProcessorOptions Classe

Definição

Define as opções de runtime ao registrar uma IEventProcessor interface com um EventHubConsumerGroup. Esse também é o mecanismo para capturar exceções de uma IEventProcessor instância usada por um objeto EventProcessorHost.

public class EventProcessorOptions
type EventProcessorOptions = class
Public Class EventProcessorOptions
Herança
EventProcessorOptions

Construtores

EventProcessorOptions()

Define as opções de runtime ao registrar uma IEventProcessor interface com um EventHubConsumerGroup. Esse também é o mecanismo para capturar exceções de uma IEventProcessor instância usada por um objeto EventProcessorHost.

Propriedades

DefaultOptions

Obtém as opções padrão, que é 10 para o MaxBatchSizee 1 minuto para a ReceiveTimeOut propriedade .

EnableReceiverRuntimeMetric

Obtém ou define um valor que indica se a métrica de runtime de um receptor está habilitada.

InitialOffsetProvider

Obtém ou define um delegado que é usado para obter o deslocamento inicial de uma determinada partição para criar EventHubReceiver. Delegate é invocado passando PartitionId e, em seguida, o usuário pode retornar o deslocamento inicial como cadeia de caracteres ou iniciando a hora UTC para receber mensagens. Isso só é usado quando Offset não é fornecido e o receptor está sendo criado pela primeira vez. Isso corresponde a ou CreateReceiverAsync(String, ReceiverOptions)CreateReceiverAsync(String, DateTime, ReceiverOptions) dependendo do tipo de valor retornado do delegado.

InvokeProcessorAfterReceiveTimeout

Habilitar essa opção fará com ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) que seja invocado após cada ReceiveTimeout quando não houver mais mensagens no fluxo para uma partição.

MaxBatchSize

Obtém ou define a contagem máxima de eventos que um usuário está disposto a aceitar para processamento por loop de recebimento. Essa contagem está em um nível de partição por Hub de Eventos.

PrefetchCount

Obtém ou define o número de eventos que qualquer receptor na partição de propriedade atual armazenará em cache ativamente. O valor padrão dessa propriedade é 300.

ReceiveTimeOut

Obtém ou define o período em que o usuário está disposto a aguardar quando o processador de eventos está executando uma operação de recebimento.

Eventos

ExceptionReceived

Esse evento é acionado sempre que uma exceção é encontrada ao processar eventos. O usuário pode registrar um manipulador nesse evento para receber notificação de exceção.

Aplica-se a