Compartir a través de


EventHubConsumerGroup.RegisterProcessor Método

Definición

Sobrecargas

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registra una implementación de IEventProcessor para empezar a consumir eventos de Event Hubs para el inicio especificado PartitionId desde Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager)

Registra una implementación de IEventProcessor para empezar a consumir eventos de Event Hubs para el inicio especificado PartitionId desde Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registra una implementación de IEventProcessor para empezar a consumir eventos de Event Hubs para el inicio especificado PartitionId desde Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

public void RegisterProcessor<T> (Microsoft.ServiceBus.Messaging.Lease lease, Microsoft.ServiceBus.Messaging.ICheckpointManager checkpointManager, Microsoft.ServiceBus.Messaging.EventProcessorOptions processorOptions) where T : Microsoft.ServiceBus.Messaging.IEventProcessor;
member this.RegisterProcessor : Microsoft.ServiceBus.Messaging.Lease * Microsoft.ServiceBus.Messaging.ICheckpointManager * Microsoft.ServiceBus.Messaging.EventProcessorOptions -> unit (requires 'T :> Microsoft.ServiceBus.Messaging.IEventProcessor)
Public Sub RegisterProcessor(Of T As IEventProcessor) (lease As Lease, checkpointManager As ICheckpointManager, processorOptions As EventProcessorOptions)

Parámetros de tipo

T

Implementación de IEventProcessor.

Parámetros

lease
Lease

Información de partición.

checkpointManager
ICheckpointManager

Controla el desplazamiento de la partición especificada cuando CheckpointAsync(EventData) se llama a .

processorOptions
EventProcessorOptions

Objeto EventProcessorOptions.

Comentarios

Para realizar una creación más avanzada IEventProcessor , implemente una IEventProcessorFactory clase que le permita controlar cómo se crean los procesadores de eventos.

Se aplica a

RegisterProcessor<T>(Lease, ICheckpointManager)

Registra una implementación de IEventProcessor para empezar a consumir eventos de Event Hubs para el inicio especificado PartitionId desde Offset. Use esta sobrecarga para crear un procesador de eventos que controle el desplazamiento del mensaje mediante una implementación personalizada de ICheckpointManager.

public void RegisterProcessor<T> (Microsoft.ServiceBus.Messaging.Lease lease, Microsoft.ServiceBus.Messaging.ICheckpointManager checkpointManager) where T : Microsoft.ServiceBus.Messaging.IEventProcessor;
member this.RegisterProcessor : Microsoft.ServiceBus.Messaging.Lease * Microsoft.ServiceBus.Messaging.ICheckpointManager -> unit (requires 'T :> Microsoft.ServiceBus.Messaging.IEventProcessor)
Public Sub RegisterProcessor(Of T As IEventProcessor) (lease As Lease, checkpointManager As ICheckpointManager)

Parámetros de tipo

T

Implementación de IEventProcessor.

Parámetros

lease
Lease

Información de partición.

checkpointManager
ICheckpointManager

Controla el desplazamiento de la partición especificada cuando CheckpointAsync(EventData) se llama a .

Comentarios

Para realizar una creación más avanzada IEventProcessor , implemente una IEventProcessorFactory clase que le permita controlar cómo se crean los procesadores de eventos.

Se aplica a