starter方法里面,设置了一些成员属性,并且构建了两个阻塞队列,分别是sendQueue和recvqueue。并且实例化了一个Messager
private void starter(QuorumPeer self, QuorumCnxManager manager) {
this.self = self;
proposedLeader = -1;
proposedZxid = -1;
sendqueue = new
LinkedBlockingQueue<ToSend>();
recvqueue = new
LinkedBlockingQueue<Notification>();
this.messenger = new Messenger(manager);
}