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 void
queuePacket(QuorumPacket pp)
void
run()
void
shutdown()
-
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:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
queuePacket
public void queuePacket(QuorumPacket pp) throws java.io.IOException
- Throws:
java.io.IOException
-
shutdown
public void shutdown()
-
-