EventHubConsumerGroup.RegisterProcessor Methode

Definition

Überlädt

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registriert eine Implementierung von, IEventProcessor um ereignisse aus Event Hubs für die angegebene PartitionId ab zu Offsetnutzen. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von prüfpunktt ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager)

Registriert eine Implementierung von, IEventProcessor um ereignisse aus Event Hubs für die angegebene PartitionId ab zu Offsetnutzen. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von prüfpunktt ICheckpointManager.

RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)

Registriert eine Implementierung von, IEventProcessor um ereignisse aus Event Hubs für die angegebene PartitionId ab zu Offsetnutzen. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von prüfpunktt 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)

Typparameter

T

Implementierung von IEventProcessor.

Parameter

lease
Lease

Partitionsinformationen.

checkpointManager
ICheckpointManager

Prüfpunkte des Offsets für die angegebene Partition, wenn CheckpointAsync(EventData) aufgerufen wird.

processorOptions
EventProcessorOptions

Ein EventProcessorOptions-Objekt.

Hinweise

Um eine erweiterte IEventProcessor Erstellung durchzuführen, implementieren Sie eine IEventProcessorFactory Klasse, mit der Sie steuern können, wie Ereignisprozessoren erstellt werden.

Gilt für:

RegisterProcessor<T>(Lease, ICheckpointManager)

Registriert eine Implementierung von, IEventProcessor um ereignisse aus Event Hubs für die angegebene PartitionId ab zu Offsetnutzen. Verwenden Sie diese Überladung, um einen Ereignisprozessor zu erstellen, der den Nachrichtenoffset mithilfe einer benutzerdefinierten Implementierung von prüfpunktt 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)

Typparameter

T

Implementierung von IEventProcessor.

Parameter

lease
Lease

Partitionsinformationen.

checkpointManager
ICheckpointManager

Prüfpunkte des Offsets für die angegebene Partition, wenn CheckpointAsync(EventData) aufgerufen wird.

Hinweise

Um eine erweiterte IEventProcessor Erstellung durchzuführen, implementieren Sie eine IEventProcessorFactory Klasse, mit der Sie steuern können, wie Ereignisprozessoren erstellt werden.

Gilt für: