ReceiverRuntimeInformation Class

  • java.lang.Object
    • com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

public final class ReceiverRuntimeInformation

Represents the temporal end of stream information of an EventHubs Partition.

Constructor Summary

Constructor Description
ReceiverRuntimeInformation(String partitionId)

Method Summary

Modifier and Type Method and Description
String getLastEnqueuedOffset()

The last enqueued EventData's offset on this EventHubs Partition

long getLastEnqueuedSequenceNumber()

The last enqueued EventData's sequence number on this EventHubs Partition

Instant getLastEnqueuedTime()

The last enqueued EventData's enqueue time stamp on this EventHubs Partition

String getPartitionId()

The Event Hubs partition id to which this information belongs to

Instant getRetrievalTime()

The value indicating when this information was retrieved from the Event Hubs service

void setRuntimeInformation(long sequenceNumber, Instant enqueuedTime, String offset)

Methods inherited from java.lang.Object

Constructor Details

ReceiverRuntimeInformation

public ReceiverRuntimeInformation(String partitionId)

Parameters:

partitionId

Method Details

getLastEnqueuedOffset

public String getLastEnqueuedOffset()

The last enqueued EventData's offset on this EventHubs Partition

Returns:

offset

getLastEnqueuedSequenceNumber

public long getLastEnqueuedSequenceNumber()

The last enqueued EventData's sequence number on this EventHubs Partition

Returns:

last enqueued sequence number

getLastEnqueuedTime

public Instant getLastEnqueuedTime()

The last enqueued EventData's enqueue time stamp on this EventHubs Partition

Returns:

last enqueued time

getPartitionId

public String getPartitionId()

The Event Hubs partition id to which this information belongs to

Returns:

the partition identifier

getRetrievalTime

public Instant getRetrievalTime()

The value indicating when this information was retrieved from the Event Hubs service

Returns:

retrieval time

setRuntimeInformation

public void setRuntimeInformation(long sequenceNumber, Instant enqueuedTime, String offset)

Parameters:

sequenceNumber
enqueuedTime
offset

Applies to