EventContext Class

Package:

com.azure.messaging.eventhubs.models

Maven Artifact:

com.azure:azure-messaging-eventhubs:5.21.0-beta.1

• java.lang.Object
• • com.azure.messaging.eventhubs.models.EventContext

public class EventContext

A class that contains EventData and the partition information the event belongs to. This is given to the processEvent(Consumer<EventContext> processEvent) and processEvent(Consumer<EventContext> processEvent, Duration maxWaitTime) handlers each time an event is received from the Event Hub or when the maxWaitTime duration has elapsed. This class also includes methods to update checkpoint in CheckpointStore and retrieve the last enqueued event information.

Constructor Summary

Constructor	Description
EventContext(PartitionContext partitionContext, EventData eventData, CheckpointStore checkpointStore, LastEnqueuedEventProperties lastEnqueuedEventProperties)	Creates an instance of EventContext.

Method Summary

Modifier and Type	Method and Description
EventData	getEventData() Returns the event data received from Event Hub.
LastEnqueuedEventProperties	getLastEnqueuedEventProperties() Returns the properties of the last enqueued event in this partition.
PartitionContext	getPartitionContext() Returns the partition information associated with the received event.
void	updateCheckpoint() Updates the checkpoint synchronously for this partition using the event data.
reactor.core.publisher.Mono<Void>	updateCheckpointAsync() Updates the checkpoint asynchronously for this partition using the event data in this EventContext.

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Details

EventContext

public EventContext(PartitionContext partitionContext, EventData eventData, CheckpointStore checkpointStore, LastEnqueuedEventProperties lastEnqueuedEventProperties)

Creates an instance of EventContext.

Parameters:

partitionContext - The partition information associated with the received event.

eventData - The event received from Event Hub.

checkpointStore - The checkpoint store that is used for updating checkpoints.

lastEnqueuedEventProperties - The properties of the last enqueued event in this partition. If trackLastEnqueuedEventProperties(boolean trackLastEnqueuedEventProperties) is set to false, this will be null.

Method Details

getEventData

public EventData getEventData()

Returns the event data received from Event Hub. Can be null if processEvent(Consumer<EventContext> processEvent, Duration maxWaitTime) was used to construct the processor. This means that no event was received during the specified duration.

Returns:

The event data received from Event Hub or null.

getLastEnqueuedEventProperties

public LastEnqueuedEventProperties getLastEnqueuedEventProperties()

Returns the properties of the last enqueued event in this partition. If trackLastEnqueuedEventProperties(boolean trackLastEnqueuedEventProperties) is set to false, this method will return null.

Returns:

The properties of the last enqueued event in this partition. If trackLastEnqueuedEventProperties(boolean trackLastEnqueuedEventProperties) is set to false, this method will return null.

getPartitionContext

public PartitionContext getPartitionContext()

Returns the partition information associated with the received event.

Returns:

The partition information of the received event.

updateCheckpoint

public void updateCheckpoint()

Updates the checkpoint synchronously for this partition using the event data. This will serve as the last known successfully processed event in this partition if the update is successful.

updateCheckpointAsync

public Mono<Void> updateCheckpointAsync()

Updates the checkpoint asynchronously for this partition using the event data in this EventContext. This will serve as the last known successfully processed event in this partition if the update is successful.

Returns:

A representation of deferred execution of this call.