EventProcessorOptions Clase

Definición

Espacio de nombres:

Microsoft.Azure.EventHubs.Processor

Ensamblado:

Microsoft.Azure.EventHubs.Processor.dll

Paquete:

Microsoft.Azure.EventHubs.Processor v4.3.2

Source:

EventProcessorOptions.cs

Define las opciones en tiempo de ejecución al registrar una IEventProcessor interfaz con un EventHubConsumerGroup. Este es también el mecanismo para detectar excepciones de una instancia de IEventProcessor usada por un EventProcessorHost objeto .

public sealed class EventProcessorOptions

type EventProcessorOptions = class

Public NotInheritable Class EventProcessorOptions

Herencia

Object

EventProcessorOptions

Constructores

EventProcessorOptions()

Crea un nuevo objeto EventProcessorOptions.

Propiedades

DefaultOptions	Devuelve una instancia de EventProcessorOptions con todas las opciones establecidas en los valores predeterminados. Los valores predeterminados son: MaxBatchSize: 10 ReceiveTimeOut: 1 minuto PrefetchCount: 300 InitialOffsetProvider: usa el último punto de control de desplazamiento o StartOfStream InvokeProcessorAfterReceiveTimeout: false
EnableReceiverRuntimeMetric	Obtiene o establece un valor que indica si la métrica en tiempo de ejecución de un receptor está habilitada.
InitialOffsetProvider	Obtiene o establece un delegado que se usa para obtener la posición inicial de una partición determinada para crear PartitionReceiver. El delegado se invoca pasando PartitionId y, a continuación, el usuario puede devolver PartitionReceiver para recibir mensajes. Esto solo se usa cuando no se encuentra un punto de control para la partición asociada.
InvokeProcessorAfterReceiveTimeout	Devuelve si EventProcessorHost llamará a IEventProcessor.OnEvents(null) cuando se produzca un tiempo de espera de recepción (true) o no (false).
MaxBatchSize	Devuelve el tamaño máximo de un lote de eventos al que se llamará IEventProcessor.ProcessEventsAsync con .
PrefetchCount	Obtiene o establece el recuento de capturas previas actuales para el cliente subyacente. El valor predeterminado es 300.
ReceiveTimeout	Obtiene o establece el tiempo de espera de las operaciones de recepción.
WebProxy	Obtiene o establece el proxy web. Un proxy solo se aplica cuando el tipo de transporte se establece en AmqpWebSockets.

Métodos

SetExceptionHandler(Action<ExceptionReceivedEventArgs>)

Establece un controlador que recibe la notificación de excepciones generales. Las excepciones que se producen durante el procesamiento de eventos de una partición concreta del centro de eventos se entregan al método onError del procesador de eventos para esa partición. Este controlador se llama en ocasiones cuando no hay ningún procesador de eventos asociado a la actividad de inicio o no se pudo crear el procesador de eventos.