EventProcessorClient.ProcessEventAsync Evento

Definición

Espacio de nombres:

Azure.Messaging.EventHubs

Ensamblado:

Azure.Messaging.EventHubs.Processor.dll

Paquete:

Azure.Messaging.EventHubs.Processor v5.11.2

Source:

EventProcessorClient.cs

Realiza las tareas necesarias para procesar un lote de eventos para una partición determinada a medida que se leen desde el servicio Event Hubs. La implementación es obligatoria.

Si se produce una excepción en el código de este método, el procesador de eventos le permitirá propagar la pila sin intentar controlarla de ninguna manera. En la mayoría de los hosts, se producirá un error en la tarea responsable del procesamiento de particiones, lo que hará que se reinicie desde el último punto de control. En algunos hosts, puede bloquear el proceso. Se recomienda encarecidamente a los desarrolladores tener en cuenta todos los escenarios de excepción y protegerse contra ellos mediante bloques try/catch y otros medios según corresponda.

No se recomienda que el estado del procesador se administre directamente desde dentro de este controlador; solicitar iniciar o detener el procesador puede dar lugar a un escenario de interbloqueo, especialmente si se usa la forma sincrónica de la llamada.

public event Func<Azure.Messaging.EventHubs.Processor.ProcessEventArgs,System.Threading.Tasks.Task> ProcessEventAsync;

member this.ProcessEventAsync : Func<Azure.Messaging.EventHubs.Processor.ProcessEventArgs, System.Threading.Tasks.Task> 

Public Custom Event ProcessEventAsync As Func(Of ProcessEventArgs, Task) 

Tipo de evento

Func<ProcessEventArgs,Task>

Excepciones

ArgumentException

Si se intenta quitar un controlador que no coincide con el controlador actual registrado.

NotSupportedException

Si se intenta agregar un controlador cuando se registra uno actualmente.

Comentarios

Este controlador se invocará simultáneamente, limitado a una llamada por partición. El procesador esperará cada invocación para asegurarse de que los eventos de la misma partición se procesan de uno a uno en el orden en que se leyeron desde la partición.

No se impone ningún límite de tiempo en una invocación de este controlador; El procesador esperará indefinidamente a que se complete la ejecución antes de enviar otro evento para la partición asociada. Es seguro que las implementaciones realicen operaciones de larga duración, reintentos, retrasos y actividades de mensajes fallidos.

Consulte también

• OnProcessingEventBatchAsync(IEnumerable<EventData>, EventProcessorPartition, CancellationToken)