public class Observer extends Learner
bufferedOutput, leaderIs, leaderOs, leaderProtocolVersion, LOG, sock
Modifier and Type | Method and Description |
---|---|
protected void |
processPacket(QuorumPacket qp)
Controls the response of an observer to the receipt of a quorumpacket
|
void |
shutdown()
Shutdown the Observer.
|
String |
toString() |
connectToLeader, findLeader, getPendingRevalidationsCount, getSocket, ping, registerWithLeader, revalidate, syncWithLeader
protected void processPacket(QuorumPacket qp) throws IOException
qp
- IOException
Copyright © 2015 The Apache Software Foundation