java.lang.Object
com.azure.spring.messaging.eventhubs.core.checkpoint.CheckpointConfig

public class CheckpointConfig extends Object
Checkpoint config to describe different checkpoint strategies.
  • Constructor Details

  • Method Details

    • getMode

      public CheckpointMode getMode()
      Get the checkpoint mode.
      Returns:
      the checkpoint mode.
    • setMode

      public void setMode(CheckpointMode mode)
      Set the checkpoint mode.
      Parameters:
      mode - the checkpoint mode.
    • getCount

      public Integer getCount()
      Get the amount of message for each partition to do one checkpoint.
      Returns:
      the amount of message for each partition to do one checkpoint.
    • setCount

      public void setCount(Integer count)
      Set the amount of message for each partition to do one checkpoint.
      Parameters:
      count - the amount of message for each partition to do one checkpoint.
    • getInterval

      public Duration getInterval()
      Get the time interval to do one checkpoint.
      Returns:
      the time interval to do one checkpoint.
    • setInterval

      public void setInterval(Duration interval)
      Set the time interval to do one checkpoint.
      Parameters:
      interval - the time interval to do one checkpoint.