IEventProcessor Interface
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.
Provides methods for event processors. Applications must implement this interface, which enables the handling of events from Event Hubs. This interface is the main extensibility point for the EventProcessorHost and RegisterProcessor<T>(Lease, ICheckpointManager).
public interface IEventProcessortype IEventProcessor = interfacePublic Interface IEventProcessorMethods
| CloseAsync(PartitionContext, CloseReason) |
Called when the ownership of partition moves to a different node for load-balancing purpose, or when the host is shutting down. Called in response to UnregisterProcessorAsync(Lease, CloseReason). |
| OpenAsync(PartitionContext) |
Initializes the Event Hub processor instance. This method is called before any event data is passed to this processor instance. |
| ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) |
Asynchronously processes the specified context and messages. This method is called when there are new messages in the Event Hubs stream. Make sure to checkpoint only when you are finished processing all the events in each batch. |
