SALES: 1-800-867-1380

EventHubConsumerGroup Methods

The EventHubConsumerGroup type exposes the following members.

  Name Description
Public method Abort Performs abort functionality on the messaging entity. (Inherited from ClientEntity.)
Public method Close Sends a cleanup message to Service Bus to signal the completion of the usage of an entity. (Inherited from ClientEntity.)
Public method CloseAsync Sends a cleanup message asynchronously to Service Bus to signal the completion of the usage of an entity. (Inherited from ClientEntity.)
Public method CreateReceiver(String) Creates a new Event Hubs receiver in the specified partition. You can use the created receiver to receive events for one Event Hubs partition, specified by partitionId.
Public method CreateReceiver(String, DateTime) Creates a new Event Hubs receiver in the specified partition, starting at the specified date and time. You can use the created receiver to receive events for one Event Hubs partition, specified by partitionId.
Public method CreateReceiver(String, Int64) Creates a new Event Hubs receiver in the specified partition, and the specified epoch value. You can use the created receiver to receive events for one Event Hubs partition, specified by partitionId.
Public method CreateReceiver(String, String) Creates a new Event Hubs receiver in the specified partition, at the specified starting offset. You can use the created receiver to receive events for one Event Hubs partition, specified by partitionId.
Public method CreateReceiver(String, DateTime, Int64) Creates a new Event Hubs receiver in the specified partition, starting at the specified date and time. You can use the created receiver to receive events for one Event Hubs partition, specified by partitionId.
Public method CreateReceiver(String, String, Int64) Creates a new Event Hubs receiver in the specified partition, at the specified starting offset.
Public method CreateReceiverAsync(String) Asynchronous version of CreateReceiver(String).
Public method CreateReceiverAsync(String, DateTime) Asynchronous version of CreateReceiver(String, DateTime).
Public method CreateReceiverAsync(String, Int64) Asynchronous version of CreateReceiver(String, Int64).
Public method CreateReceiverAsync(String, String) Asynchronous version of CreateReceiver(String, String).
Public method CreateReceiverAsync(String, DateTime, Int64) Asynchronous version of CreateReceiver(String, DateTime, Int64).
Public method CreateReceiverAsync(String, String, Int64) Asynchronous version of CreateReceiver(String, String, Int64).
Public method Equals (Inherited from Object.)
Public method GetHashCode (Inherited from Object.)
Public method GetType (Inherited from Object.)
Public method 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 method 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 method RegisterProcessorAsync<T>(Lease, ICheckpointManager) Asynchronous version of RegisterProcessor<T>(Lease, ICheckpointManager).
Public method RegisterProcessorAsync<T>(Lease, ICheckpointManager, EventProcessorOptions) Asynchronous version of RegisterProcessor<T>(Lease, ICheckpointManager, EventProcessorOptions).
Public method RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory) Registers the IEventProcessorFactory object used to create an instance of IEventProcessor in order to start consuming events for the partition specified by PartitionId, starting from Offset. Use this overload to create an event processor that checkpoints the message offset using a custom implementation of ICheckpointManager.
Public method RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions) Registers the IEventProcessorFactory object used to create an instance of IEventProcessor in order to start consuming events for the partition specified by PartitionId, starting from Offset. Use this overload to create an event processor that checkpoints the message offset using a custom implementation of ICheckpointManager.
Public method RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory) Asynchronous version of RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory).
Public method RegisterProcessorFactoryAsync(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions) Asynchronous version of RegisterProcessorFactory(Lease, ICheckpointManager, IEventProcessorFactory, EventProcessorOptions).
Public method ToString (Inherited from Object.)
Public method UnregisterProcessor Unregisters IEventProcessor for the partition specified by PartitionId. This results in CloseAsync(PartitionContext, CloseReason) being called on the underlying event processor.
Public method UnregisterProcessorAsync Asynchronous version of UnregisterProcessor(Lease, CloseReason).
Top
Was this page helpful?
(1500 characters remaining)
Thank you for your feedback

Community Additions

ADD
Show:
© 2014 Microsoft