EventHubConsumerGroup.RegisterProcessorAsync Method

  • Reference

Definition

Namespace:
Microsoft.ServiceBus.Messaging
Assembly:
Microsoft.ServiceBus.dll
Package:
WindowsAzure.ServiceBus v6.2.2

Overloads

RegisterProcessorAsync<T>(Lease, ICheckpointManager)

Asynchronous version of RegisterProcessor<T>(Lease, ICheckpointManager).
RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)

Asynchronous version of RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).

RegisterProcessorAsync<T>(Lease, ICheckpointManager)

Asynchronous version of RegisterProcessor<T>(Lease, ICheckpointManager).

public System.Threading.Tasks.Task RegisterProcessorAsync<T> (Microsoft.ServiceBus.Messaging.Lease lease, Microsoft.ServiceBus.Messaging.ICheckpointManager checkpointManager) where T : Microsoft.ServiceBus.Messaging.IEventProcessor;
member this.RegisterProcessorAsync : Microsoft.ServiceBus.Messaging.Lease * Microsoft.ServiceBus.Messaging.ICheckpointManager -> System.Threading.Tasks.Task (requires 'T :> Microsoft.ServiceBus.Messaging.IEventProcessor)
Public Function RegisterProcessorAsync(Of T As IEventProcessor) (lease As Lease, checkpointManager As ICheckpointManager) As Task

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.

Returns

Task

A task instance that represents the asynchronous operation.

Applies to

RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions)

Asynchronous version of RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).

public System.Threading.Tasks.Task RegisterProcessorAsync<T> (Microsoft.ServiceBus.Messaging.Lease lease, Microsoft.ServiceBus.Messaging.ICheckpointManager checkpointManager, Microsoft.ServiceBus.Messaging.EventProcessorOptions processorOptions) where T : Microsoft.ServiceBus.Messaging.IEventProcessor;
member this.RegisterProcessorAsync : Microsoft.ServiceBus.Messaging.Lease * Microsoft.ServiceBus.Messaging.ICheckpointManager * Microsoft.ServiceBus.Messaging.EventProcessorOptions -> System.Threading.Tasks.Task (requires 'T :> Microsoft.ServiceBus.Messaging.IEventProcessor)
Public Function RegisterProcessorAsync(Of T As IEventProcessor) (lease As Lease, checkpointManager As ICheckpointManager, processorOptions As EventProcessorOptions) As Task

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.

Returns

Task

Returns Task.

Remarks

To perform more advanced IEventProcessor creation, implement an IEventProcessorFactory class which allows you to control how event processors are created.

Applies to