Share via

Checkpoint Class

  • Reference
Package:
com.azure.messaging.eventhubs.models
Maven Artifact:
com.azure:azure-messaging-eventhubs:5.19.1
  • java.lang.Object
    • com.azure.messaging.eventhubs.models.Checkpoint

public class Checkpoint

A model class to hold checkpoint data. A checkpoint represents the last successfully processed event for a particular partition of an Event Hub.

Constructor Summary

Constructor Description
Checkpoint()

Creates a new instance.

Method Summary

Modifier and Type Method and Description
String getConsumerGroup()

Gets the consumer group name associated with this checkpoint.
String getEventHubName()

Gets the Event Hub name associated with this checkpoint.
String getFullyQualifiedNamespace()

Returns the fully qualified namespace of the Event Hub.
Long getOffset()

Gets the offset of the last successfully processed event to store as checkpoint.
String getPartitionId()

Gets the partition id associated with this checkpoint.
Long getSequenceNumber()

Gets the sequence number of the last successfully processed event to store as checkpoint.
Checkpoint setConsumerGroup(String consumerGroup)

Sets the consumer group name associated with this checkpoint.
Checkpoint setEventHubName(String eventHubName)

Sets the Event Hub name associated with this checkpoint.
Checkpoint setFullyQualifiedNamespace(String fullyQualifiedNamespace)

Sets the fully qualified namespace of the Event Hub.
Checkpoint setOffset(Long offset)

Sets the offset of the last successfully processed event to store as checkpoint.
Checkpoint setPartitionId(String partitionId)

Sets the partition id associated with this checkpoint.
Checkpoint setSequenceNumber(Long sequenceNumber)

Sets the sequence number of the last successfully processed event to store as checkpoint.

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Details

Checkpoint

public Checkpoint()

Creates a new instance.

Method Details

getConsumerGroup

public String getConsumerGroup()

Gets the consumer group name associated with this checkpoint.

Returns:

The consumer group name associated with this checkpoint.

getEventHubName

public String getEventHubName()

Gets the Event Hub name associated with this checkpoint.

Returns:

The Event Hub name associated with this checkpoint.

getFullyQualifiedNamespace

public String getFullyQualifiedNamespace()

Returns the fully qualified namespace of the Event Hub.

Returns:

the fully qualified namespace of the Event Hub.

getOffset

public Long getOffset()

Gets the offset of the last successfully processed event to store as checkpoint.

Returns:

The offset of the last successfully processed event to store as checkpoint.

getPartitionId

public String getPartitionId()

Gets the partition id associated with this checkpoint.

Returns:

The partition id associated with this checkpoint.

getSequenceNumber

public Long getSequenceNumber()

Gets the sequence number of the last successfully processed event to store as checkpoint.

Returns:

The sequence number of the last successfully processed event to store as checkpoint.

setConsumerGroup

public Checkpoint setConsumerGroup(String consumerGroup)

Sets the consumer group name associated with this checkpoint.

Parameters:

consumerGroup - The consumer group name associated with this checkpoint.

Returns:

The updated Checkpoint instance.

setEventHubName

public Checkpoint setEventHubName(String eventHubName)

Sets the Event Hub name associated with this checkpoint.

Parameters:

eventHubName - The Event Hub name associated with this checkpoint.

Returns:

The updated Checkpoint instance.

setFullyQualifiedNamespace

public Checkpoint setFullyQualifiedNamespace(String fullyQualifiedNamespace)

Sets the fully qualified namespace of the Event Hub.

Parameters:

fullyQualifiedNamespace - the fully qualified namespace of the Event Hub.

Returns:

The updated Checkpoint instance.

setOffset

public Checkpoint setOffset(Long offset)

Sets the offset of the last successfully processed event to store as checkpoint.

Parameters:

offset - The offset of the last successfully processed event to store as checkpoint.

Returns:

The updated Checkpoint instance.

setPartitionId

public Checkpoint setPartitionId(String partitionId)

Sets the partition id associated with this checkpoint.

Parameters:

partitionId - The partition id associated with this checkpoint.

Returns:

The updated Checkpoint instance.

setSequenceNumber

public Checkpoint setSequenceNumber(Long sequenceNumber)

Sets the sequence number of the last successfully processed event to store as checkpoint.

Parameters:

sequenceNumber - The sequence number of the last successfully processed event to store as checkpoint.

Returns:

The updated Checkpoint instance.

Applies to