Class LearnerSender
- java.lang.Object
-
- java.lang.Thread
-
- org.apache.zookeeper.server.ZooKeeperThread
-
- org.apache.zookeeper.server.ZooKeeperCriticalThread
-
- org.apache.zookeeper.server.quorum.LearnerSender
-
- All Implemented Interfaces:
java.lang.Runnable
public class LearnerSender extends ZooKeeperCriticalThread
-
-
Constructor Summary
Constructors Constructor Description LearnerSender(Learner learner)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidqueuePacket(QuorumPacket pp)voidrun()voidshutdown()-
Methods inherited from class org.apache.zookeeper.server.ZooKeeperCriticalThread
handleException
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Constructor Detail
-
LearnerSender
public LearnerSender(Learner learner)
-
-
Method Detail
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
queuePacket
public void queuePacket(QuorumPacket pp) throws java.io.IOException
- Throws:
java.io.IOException
-
shutdown
public void shutdown()
-
-