Microsoft.Azure.EventHubs.Processor Namespace
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.
Classes
Checkpoint |
The context object used to preserve state in the stream. |
EventProcessorConfigurationException |
An exception which specifies that the EventProcessorHost configuration is incorrect. |
EventProcessorHost |
Represents a host for processing Event Hubs event data. |
EventProcessorOptions |
Defines the runtime options when registering an IEventProcessor interface with an EventHubConsumerGroup. This is also the mechanism for catching exceptions from an IEventProcessor instance used by an EventProcessorHost object. |
EventProcessorRuntimeException |
An exception thrown during event processing. |
ExceptionReceivedEventArgs |
Provides data for the Microsoft.Azure.EventHubs.Processor.EventProcessorOptions.NotifyOfException(System.String,System.String,System.Exception,System.String) event. |
Lease |
Contains partition ownership information. |
LeaseLostException |
Represents an exception that occurs when the service lease has been lost. |
PartitionContext |
Encapsulates information related to an Event Hubs partition used by IEventProcessor. |
PartitionManagerOptions |
Options to control various aspects of partition distribution happening within EventProcessorHost instance. |
Interfaces
ICheckpointManager |
If you wish to have EventProcessorHost store checkpoints somewhere other than Azure Storage, you can write your own checkpoint manager using this interface. The Azure Storage managers use the same storage for both lease and checkpoints, so both interfaces are implemented by the same class. You are free to do the same thing if you have a unified store for both types of data. This interface does not specify initialization methods because we have no way of knowing what information your implementation will require. |
IEventProcessor |
Interface that must be implemented by event processor classes. Any given instance of an event processor class will only process events from one partition of one Event Hub. A PartitionContext is provided with each call to the event processor because some parameters could change, but it will always be the same partition. Although EventProcessorHost is multithreaded, calls to a given instance of an event processor class are serialized, except for OnError(). OnOpen() is called first, then OnEvents() will be called zero or more times. When the event processor needs to be shut down, whether because there was a failure somewhere, or the lease for the partition has been lost, or because the entire processor host is being shut down, OnClose() is called after the last OnEvents() call returns. OnError() could be called while OnEvents() or OnClose() is executing. No synchronization is attempted in order to avoid possibly deadlocking. |
IEventProcessorFactory |
Interface that must be implemented by an event processor factory class. User-provided factories are needed if creating an event processor object requires more work than just a new with a parameterless constructor. |
ILeaseManager |
If you wish to have EventProcessorHost store leases somewhere other than Azure Storage, you can write your own lease manager using this interface. The Azure Storage managers use the same storage for both lease and checkpoints, so both interfaces are implemented by the same class. You are free to do the same thing if you have a unified store for both types of data. This interface does not specify initialization methods because we have no way of knowing what information your implementation will require. |
Enums
CloseReason |
Reason for closing an EventProcessorHost. |
Azure SDK for .NET