Uses of Interface
com.microsoft.azure.eventhubs.EventPosition
-
Packages that use EventPosition Package Description com.microsoft.azure.eventhubs com.microsoft.azure.eventhubs.impl -
-
Uses of EventPosition in com.microsoft.azure.eventhubs
Methods in com.microsoft.azure.eventhubs that return EventPosition Modifier and Type Method Description static EventPosition
EventPosition. fromEndOfStream()
Returns the position for the end of a stream.static EventPosition
EventPosition. fromEnqueuedTime(Instant dateTime)
Creates a position at the givenInstant
.static EventPosition
EventPosition. fromOffset(String offset)
Creates a position at the given offset.static EventPosition
EventPosition. fromOffset(String offset, boolean inclusiveFlag)
Creates a position at the given offset.static EventPosition
EventPosition. fromSequenceNumber(Long sequenceNumber)
Creates a position at the given sequence number.static EventPosition
EventPosition. fromSequenceNumber(Long sequenceNumber, boolean inclusiveFlag)
Creates a position at the given sequence number.static EventPosition
EventPosition. fromStartOfStream()
Returns the position for the start of a stream.EventPosition
PartitionReceiver. getEventPosition()
Get theEventPosition
that corresponds to anEventData
which was returned last by the receiver.Methods in com.microsoft.azure.eventhubs with parameters of type EventPosition Modifier and Type Method Description CompletableFuture<PartitionReceiver>
EventHubClient. createEpochReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition, long epoch)
Create a Epoch based EventHub receiver with given partition id and start receiving from the beginning of the partition stream.CompletableFuture<PartitionReceiver>
EventHubClient. createEpochReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition, long epoch, ReceiverOptions receiverOptions)
Create a Epoch based EventHub receiver with given partition id and start receiving from the beginning of the partition stream.default PartitionReceiver
EventHubClient. createEpochReceiverSync(String consumerGroupName, String partitionId, EventPosition eventPosition, long epoch)
Synchronous version ofEventHubClient.createEpochReceiver(String, String, EventPosition, long)
.default PartitionReceiver
EventHubClient. createEpochReceiverSync(String consumerGroupName, String partitionId, EventPosition eventPosition, long epoch, ReceiverOptions receiverOptions)
Synchronous version ofEventHubClient.createEpochReceiver(String, String, EventPosition, long)
.CompletableFuture<PartitionReceiver>
EventHubClient. createReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition)
Create the EventHub receiver with given partition id and start receiving from the specified starting offset.CompletableFuture<PartitionReceiver>
EventHubClient. createReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition, ReceiverOptions receiverOptions)
Create the EventHub receiver with given partition id and start receiving from the specified starting offset.default PartitionReceiver
EventHubClient. createReceiverSync(String consumerGroupName, String partitionId, EventPosition eventPosition)
Synchronous version ofEventHubClient.createReceiver(String, String, EventPosition)
.default PartitionReceiver
EventHubClient. createReceiverSync(String consumerGroupName, String partitionId, EventPosition eventPosition, ReceiverOptions receiverOptions)
Synchronous version ofEventHubClient.createReceiver(String, String, EventPosition)
. -
Uses of EventPosition in com.microsoft.azure.eventhubs.impl
Classes in com.microsoft.azure.eventhubs.impl that implement EventPosition Modifier and Type Class Description class
EventPositionImpl
Methods in com.microsoft.azure.eventhubs.impl with parameters of type EventPosition Modifier and Type Method Description CompletableFuture<PartitionReceiver>
EventHubClientImpl. createEpochReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition, long epoch)
CompletableFuture<PartitionReceiver>
EventHubClientImpl. createEpochReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition, long epoch, ReceiverOptions receiverOptions)
CompletableFuture<PartitionReceiver>
EventHubClientImpl. createReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition)
CompletableFuture<PartitionReceiver>
EventHubClientImpl. createReceiver(String consumerGroupName, String partitionId, EventPosition eventPosition, ReceiverOptions receiverOptions)
-