Uses of Class
com.azure.messaging.eventhubs.models.EventPosition
Package
Description
Package containing classes for creating
EventHubProducerAsyncClient
,
EventHubProducerClient
,
EventHubConsumerAsyncClient
,
EventHubConsumerClient
, or
EventProcessorClient
to perform operations on Azure Event Hubs.Package containing classes used for creating and configuring events that are being sent-to and received-from Azure
Event Hubs service.
-
Uses of EventPosition in com.azure.messaging.eventhubs
Modifier and TypeMethodDescriptionEventHubConsumerAsyncClient.receiveFromPartition
(String partitionId, EventPosition startingPosition) Consumes events from a single partition starting atstartingPosition
.EventHubConsumerAsyncClient.receiveFromPartition
(String partitionId, EventPosition startingPosition, ReceiveOptions receiveOptions) Consumes events from a single partition starting atstartingPosition
with a set ofreceive options
.EventHubConsumerClient.receiveFromPartition
(String partitionId, int maximumMessageCount, EventPosition startingPosition) Receives a batch ofevents
from the Event Hub partition.EventHubConsumerClient.receiveFromPartition
(String partitionId, int maximumMessageCount, EventPosition startingPosition, Duration maximumWaitTime) Receives a batch ofevents
from the Event Hub partition.EventHubConsumerClient.receiveFromPartition
(String partitionId, int maximumMessageCount, EventPosition startingPosition, Duration maximumWaitTime, ReceiveOptions receiveOptions) Receives a batch ofevents
from the Event Hub partition.Modifier and TypeMethodDescriptionEventProcessorClientBuilder.initialPartitionEventPosition
(Map<String, EventPosition> initialPartitionEventPosition) Sets the map containing the event position to use for each partition if a checkpoint for the partition does not exist inCheckpointStore
. -
Uses of EventPosition in com.azure.messaging.eventhubs.models
Modifier and TypeMethodDescriptionstatic EventPosition
EventPosition.earliest()
Corresponds to the location of the first event present in the partition.static EventPosition
EventPosition.fromEnqueuedTime
(Instant enqueuedDateTime) Creates a position at the givenInstant
.static EventPosition
EventPosition.fromOffset
(long offset) Creates a position to an event in the partition at the provided offset.static EventPosition
EventPosition.fromSequenceNumber
(long sequenceNumber) Creates a position to an event in the partition at the provided sequence number.static EventPosition
EventPosition.fromSequenceNumber
(long sequenceNumber, boolean isInclusive) Creates a position at the given sequence number.static EventPosition
EventPosition.latest()
Corresponds to the end of the partition, where no more events are currently enqueued.