Package | Description |
---|---|
org.apache.zookeeper.server.quorum |
Modifier and Type | Field | Description |
---|---|---|
java.util.concurrent.ArrayBlockingQueue<QuorumCnxManager.Message> |
QuorumCnxManager.recvQueue |
Modifier and Type | Method | Description |
---|---|---|
QuorumCnxManager.Message |
QuorumCnxManager.pollRecvQueue(long timeout,
java.util.concurrent.TimeUnit unit) |
Retrieves and removes a message at the head of this queue,
waiting up to the specified wait time if necessary for an element to
become available.
|
Modifier and Type | Method | Description |
---|---|---|
void |
QuorumCnxManager.addToRecvQueue(QuorumCnxManager.Message msg) |
Inserts an element in the
QuorumCnxManager.recvQueue . |
Copyright © 2018 The Apache Software Foundation