EventHubConsumerGroup.RegisterProcessor Méthode

Définition

Espace de noms:

Microsoft.ServiceBus.Messaging

Assembly:

Microsoft.ServiceBus.dll

Paquet:

WindowsAzure.ServiceBus v6.2.2

Surcharges

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)	Inscrit une implémentation de afin de IEventProcessor commencer à consommer des événements à partir d’Event Hubs pour le spécifié PartitionId à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée de ICheckpointManager.
RegisterProcessor<T>(Lease, ICheckpointManager)	Inscrit une implémentation de afin de IEventProcessor commencer à consommer des événements à partir d’Event Hubs pour le spécifié PartitionId à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée de ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Inscrit une implémentation de afin de IEventProcessor commencer à consommer des événements à partir d’Event Hubs pour le spécifié PartitionId à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée 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)

Paramètres de type

T

Implémentation de IEventProcessor.

Paramètres

lease

Lease

Informations de partition.

checkpointManager

ICheckpointManager

Points de contrôle le décalage de la partition spécifiée quand CheckpointAsync(EventData) est appelée.

processorOptions

EventProcessorOptions

Objet EventProcessorOptions.

Remarques

Pour effectuer une création plus avancée IEventProcessor , implémentez une IEventProcessorFactory classe qui vous permet de contrôler la façon dont les processeurs d’événements sont créés.

RegisterProcessor<T>(Lease, ICheckpointManager)

Inscrit une implémentation de afin de IEventProcessor commencer à consommer des événements à partir d’Event Hubs pour le spécifié PartitionId à partir de Offset. Utilisez cette surcharge pour créer un processeur d’événements qui contrôle le décalage de message à l’aide d’une implémentation personnalisée 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)

Paramètres de type

T

Implémentation de IEventProcessor.

Paramètres

lease

Lease

Informations de partition.

checkpointManager

ICheckpointManager

Points de contrôle le décalage de la partition spécifiée quand CheckpointAsync(EventData) est appelée.

Remarques

Pour effectuer une création plus avancée IEventProcessor , implémentez une IEventProcessorFactory classe qui vous permet de contrôler la façon dont les processeurs d’événements sont créés.