Class Follower


  • public class Follower
    extends Learner
    This class has the control logic for the Follower.
    • Method Detail

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • processPacket

        protected void processPacket​(QuorumPacket qp)
                              throws java.lang.Exception
        Examine the packet received in qp and dispatch based on its contents.
        Parameters:
        qp -
        Throws:
        java.io.IOException
        java.lang.Exception
      • getZxid

        public long getZxid()
        The zxid of the last operation seen
        Returns:
        zxid
      • getLastQueued

        protected long getLastQueued()
        The zxid of the last operation queued
        Returns:
        zxid
      • getSyncedObserverSize

        public java.lang.Integer getSyncedObserverSize()
      • getSyncedObserversInfo

        public java.lang.Iterable<java.util.Map<java.lang.String,​java.lang.Object>> getSyncedObserversInfo()
      • resetObserverConnectionStats

        public void resetObserverConnectionStats()
      • shutdown

        public void shutdown()
        Description copied from class: Learner
        Shutdown the Peer
        Overrides:
        shutdown in class Learner