Class QueueState


  • public class QueueState
    extends Object
    • Constructor Detail

      • QueueState

        public QueueState​(long lastProcessedOffset,
                          int headRetries,
                          int maxRetries,
                          ClearCallback clearCallback)
    • Method Detail

      • getLastProcessedOffset

        public long getLastProcessedOffset()
      • getHeadRetries

        public int getHeadRetries()
      • getMaxRetries

        public int getMaxRetries()