EventProcessorOptions Classe

Referência

Definição

Namespace:: Microsoft.Azure.EventHubs.Processor

Assembly:: Microsoft.Azure.EventHubs.Processor.dll

Pacote:: Microsoft.Azure.EventHubs.Processor v4.3.2

Origem:: EventProcessorOptions.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.

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 instância IEventProcessor usada por um EventProcessorHost objeto .

public sealed class EventProcessorOptions

type EventProcessorOptions = class

Public NotInheritable Class EventProcessorOptions

Herança: Object
EventProcessorOptions

Construtores

EventProcessorOptions()

Cria um novo objeto EventProcessorOptions.

Propriedades

DefaultOptions	Retorna uma instância eventProcessorOptions com todas as opções definidas para os valores padrão. Os valores padrão são: MaxBatchSize: 10 ReceiveTimeOut: 1 minuto PrefetchCount: 300 InitialOffsetProvider: usa o último deslocamento com ponto de verificação ou StartOfStream InvokeProcessorAfterReceiveTimeout: false
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 a posição inicial de uma determinada partição para criar PartitionReceiver. O delegado é invocado passando PartitionId e, em seguida, o usuário pode retornar PartitionReceiver para receber mensagens. Isso só é usado quando um ponto de verificação não pode ser encontrado para a partição associada.
InvokeProcessorAfterReceiveTimeout	Retorna se o EventProcessorHost chamará IEventProcessor.OnEvents(null) quando ocorrer um tempo limite de recebimento (true) ou não (false).
MaxBatchSize	Retorna o tamanho máximo de um lote de eventos com o qual IEventProcessor.ProcessEventsAsync será chamado com
PrefetchCount	Obtém ou define a contagem de pré-busca atual para o cliente subjacente. O padrão é 300.
ReceiveTimeout	Obtém ou define o tempo limite para operações de recebimento.
WebProxy	Obtém ou define o proxy Web. Um proxy é aplicável somente quando o tipo de transporte é definido como AmqpWebSockets.

Métodos

SetExceptionHandler(Action<ExceptionReceivedEventArgs>)

Define um manipulador que recebe notificação de exceções gerais.

Exceções que ocorrem durante o processamento de eventos de uma partição específica do Hub de Eventos são entregues ao método onError do processador de eventos para essa partição. Esse manipulador é chamado em ocasiões em que não há processador de eventos associado à atividade de lançamento ou o processador de eventos não pôde ser criado.

Aplica-se a

Compartilhar via