EventProcessorOptions Clase

Definición

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

public class EventProcessorOptions
type EventProcessorOptions = class
Public Class EventProcessorOptions
Herencia
EventProcessorOptions

Constructores

EventProcessorOptions()

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

Propiedades

DefaultOptions

Obtiene las opciones predeterminadas, que son 10 para y MaxBatchSize1 minuto para la ReceiveTimeOut propiedad .

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 el desplazamiento inicial de una partición determinada para crear EventHubReceiver. El delegado se invoca pasando PartitionId y, a continuación, el usuario puede devolver el desplazamiento inicial como cadena o la hora UTC inicial para recibir mensajes. Esto solo se usa cuando Offset no se proporciona y el receptor se crea por primera vez. Esto corresponde a o CreateReceiverAsync(String, ReceiverOptions)CreateReceiverAsync(String, DateTime, ReceiverOptions) según el tipo de valor devuelto del delegado.

InvokeProcessorAfterReceiveTimeout

Al habilitar esta opción, se invocará ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) después de cada ReceiveTimeout cuando no haya más mensajes en la secuencia para una partición.

MaxBatchSize

Obtiene o establece el recuento máximo de eventos que un usuario está dispuesto a aceptar para su procesamiento por bucle de recepción. Este recuento está en un nivel de partición por centro de eventos.

PrefetchCount

Obtiene o establece el número de eventos que cualquier receptor de la partición que posee actualmente almacenará en caché de forma activa. El valor predeterminado de esta propiedad es 300.

ReceiveTimeOut

Obtiene o establece el intervalo de tiempo en el que el usuario está dispuesto a esperar cuando el procesador de eventos está realizando una operación de recepción.

Eventos

ExceptionReceived

Este evento se desencadena siempre que se encuentra una excepción al procesar eventos. El usuario puede registrar un controlador en este evento para obtener una notificación de excepción.

Se aplica a