EventProcessorHost Clase

Referencia

Definición

Espacio de nombres:: Microsoft.ServiceBus.Messaging

Ensamblado:: Microsoft.ServiceBus.Messaging.EventProcessorHost.dll

Paquete:: Microsoft.Azure.ServiceBus.EventProcessorHost v5.0.1

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

Un host muy sencillo para procesar mensajes de EventHub. Se encarga de distribuir particiones de EventHub entre instancias de EventProcessorHost. Crea un blob en bloques de Azure para cada partición de EventHub y usa estos blobs para administrar la concesión de una partición. Cada instancia de EventProcessorHost realiza las dos tareas siguientes: 1) Renovar concesiones: realiza un seguimiento de las concesiones que posee actualmente el host y mantiene continuamente la renovación de las concesiones. 2) Adquirir concesiones: cada instancia sondea continuamente todos los blobs de concesión para comprobar si hay concesiones que debe adquirir para que el sistema entre en estado equilibrado. La aplicación cliente debe implementar IEventProcessor y registrar la implementación del procesador con EventProcessorHost.

public class EventProcessorHost : IDisposable

type EventProcessorHost = class
    interface IDisposable

Public Class EventProcessorHost
Implements IDisposable

Herencia: Object
EventProcessorHost

Implementaciones: IDisposable

Constructores

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)	Crea una nueva instancia de EventProcessorHost.
EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)	Crea una nueva instancia de EventProcessorHost.
EventProcessorHost(String, String, String, String)	Crea una nueva instancia de EventProcessorHost.
EventProcessorHost(String, String, String, String, String)	Inicializa una nueva instancia de la clase EventProcessorHost.
EventProcessorHost(String, String, String, String, String, String, String)	Inicializa una nueva instancia de la clase EventProcessorHost.

Propiedades

HostName	Obtiene el nombre de host, que es un nombre único para la EventProcessorHost instancia.
PartitionManagerOptions	Obtiene o establece la PartitionManagerOptions instancia usada por el EventProcessorHost objeto .

Métodos

Dispose()	Un host muy sencillo para procesar mensajes de EventHub. Se encarga de distribuir particiones de EventHub entre instancias de EventProcessorHost. Crea un blob en bloques de Azure para cada partición de EventHub y usa estos blobs para administrar la concesión de una partición. Cada instancia de EventProcessorHost realiza las dos tareas siguientes: 1) Renovar concesiones: realiza un seguimiento de las concesiones que posee actualmente el host y mantiene continuamente la renovación de las concesiones. 2) Adquirir concesiones: cada instancia sondea continuamente todos los blobs de concesión para comprobar si hay concesiones que debe adquirir para que el sistema entre en estado equilibrado. La aplicación cliente debe implementar IEventProcessor y registrar la implementación del procesador con EventProcessorHost.
Dispose(Boolean)	Un host muy sencillo para procesar mensajes de EventHub. Se encarga de distribuir particiones de EventHub entre instancias de EventProcessorHost. Crea un blob en bloques de Azure para cada partición de EventHub y usa estos blobs para administrar la concesión de una partición. Cada instancia de EventProcessorHost realiza las dos tareas siguientes: 1) Renovar concesiones: realiza un seguimiento de las concesiones que posee actualmente el host y mantiene continuamente la renovación de las concesiones. 2) Adquirir concesiones: cada instancia sondea continuamente todos los blobs de concesión para comprobar si hay concesiones que debe adquirir para que el sistema entre en estado equilibrado. La aplicación cliente debe implementar IEventProcessor y registrar la implementación del procesador con EventProcessorHost.
RegisterEventProcessorAsync<T>()	Registra de forma asincrónica la implementación de la IEventProcessor interfaz con el host mediante el DefaultEventProcessorFactory<T> generador. Este método también inicia el host y permite que comience a participar en el proceso de distribución de particiones.
RegisterEventProcessorAsync<T>(EventProcessorOptions)	Esto registra la IEventProcessor implementación con el host mediante DefaultEventProcessorFactory<T>. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	Esto registra IEventProcessorFactory la implementación con el host que se usa para crear una instancia de IEventProcessor cuando toma posesión de una partición. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	Esto registra IEventProcessorFactory la implementación con el host que se usa para crear una instancia de IEventProcessor cuando toma posesión de una partición. Esto también inicia el host y hace que empiece a participar en el proceso de distribución de particiones.
ResetAllConnections()	Restablezca todas las conexiones del receptor de Event Hubs usadas por esta instancia de EventProcessorHost.
ResetConnection(String)	Un host muy sencillo para procesar mensajes de EventHub. Se encarga de distribuir particiones de EventHub entre instancias de EventProcessorHost. Crea un blob en bloques de Azure para cada partición de EventHub y usa estos blobs para administrar la concesión de una partición. Cada instancia de EventProcessorHost realiza las dos tareas siguientes: 1) Renovar concesiones: realiza un seguimiento de las concesiones que posee actualmente el host y mantiene continuamente la renovación de las concesiones. 2) Adquirir concesiones: cada instancia sondea continuamente todos los blobs de concesión para comprobar si hay concesiones que debe adquirir para que el sistema entre en estado equilibrado. La aplicación cliente debe implementar IEventProcessor y registrar la implementación del procesador con EventProcessorHost.
UnregisterEventProcessorAsync()	Apaga de forma asincrónica la EventProcessorHost instancia. Este método mantiene las concesiones en todas las particiones que se mantienen actualmente y permite que cada IEventProcessor instancia se apague limpiamente invocando el método con un Shutdown objeto después de que se complete la CloseAsync(PartitionContext, CloseReason) ejecución actual de ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) .

Se aplica a

Compartir a través de