IEventProcessor Interfaz

Definición

Interfaz que deben implementar las clases de procesador de eventos.

Cualquier instancia determinada de una clase de procesador de eventos solo procesará eventos de una partición de un centro de eventos. PartitionContext se proporciona con cada llamada al procesador de eventos porque algunos parámetros podrían cambiar, pero siempre será la misma partición.

Aunque EventProcessorHost es multiproceso, las llamadas a una instancia determinada de una clase de procesador de eventos se serializan, excepto OnError(). Primero se llama a OnOpen() y, a continuación, a OnEvents() se le llamará cero o más veces. Cuando es necesario apagar el procesador de eventos, ya sea porque se produjo un error en algún lugar o se ha perdido la concesión de la partición, o porque se está cerrando todo el host del procesador, se llama a OnClose() después de que se devuelva la última llamada a OnEvents().

Se podría llamar a OnError() mientras onEvents() o OnClose() se está ejecutando. No se intenta realizar ninguna sincronización para evitar posiblemente interbloqueos.

public interface IEventProcessor
type IEventProcessor = interface
Public Interface IEventProcessor

Métodos

CloseAsync(PartitionContext, CloseReason)

Lo llama el host del procesador para indicar que el procesador de eventos se está deteniendo.

OpenAsync(PartitionContext)

Lo llama el host del procesador para inicializar el procesador de eventos.

ProcessErrorAsync(PartitionContext, Exception)

Se llama cuando el cliente subyacente experimenta un error al recibir. EventProcessorHost se encargará de recuperarse del error y continuar bombeando mensajes, por lo que no se requiere ninguna acción del código. Este método se proporciona con fines informativos.

ProcessEventsAsync(PartitionContext, IEnumerable<EventData>)

Lo llama el host del procesador cuando ha llegado un lote de eventos.

Aquí es donde se realiza el trabajo real del procesador de eventos.

Se aplica a