EventHubConsumerGroup.RegisterProcessor Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions) |
Registers an implementation of IEventProcessor in order to start consuming events from Event Hubs for the specified PartitionId starting from Offset. Use this overload to create an event processor that checkpoints the message offset using a custom implementation of ICheckpointManager. |
RegisterProcessor<T>(Lease, ICheckpointManager) |
Registers an implementation of IEventProcessor in order to start consuming events from Event Hubs for the specified PartitionId starting from Offset. Use this overload to create an event processor that checkpoints the message offset using a custom implementation of ICheckpointManager. |
RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions)
Registers an implementation of IEventProcessor in order to start consuming events from Event Hubs for the specified PartitionId starting from Offset. Use this overload to create an event processor that checkpoints the message offset using a custom implementation of 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)
Type Parameters
- T
Implementation of IEventProcessor.
Parameters
- lease
- Lease
Partition information.
- checkpointManager
- ICheckpointManager
Checkpoints the offset for the specified partition when CheckpointAsync(EventData) is called.
- processorOptions
- EventProcessorOptions
An EventProcessorOptions object.
Remarks
To perform more advanced IEventProcessor creation, implement an IEventProcessorFactory class which allows you to control how event processors are created.
Applies to
RegisterProcessor<T>(Lease, ICheckpointManager)
Registers an implementation of IEventProcessor in order to start consuming events from Event Hubs for the specified PartitionId starting from Offset. Use this overload to create an event processor that checkpoints the message offset using a custom implementation of 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)
Type Parameters
- T
Implementation of IEventProcessor.
Parameters
- lease
- Lease
Partition information.
- checkpointManager
- ICheckpointManager
Checkpoints the offset for the specified partition when CheckpointAsync(EventData) is called.
Remarks
To perform more advanced IEventProcessor creation, implement an IEventProcessorFactory class which allows you to control how event processors are created.