Package | Description |
---|---|
org.apache.zookeeper.server.quorum |
Modifier and Type | Field and Description |
---|---|
ArrayBlockingQueue<QuorumCnxManager.Message> |
QuorumCnxManager.recvQueue |
Modifier and Type | Method and Description |
---|---|
QuorumCnxManager.Message |
QuorumCnxManager.pollRecvQueue(long timeout,
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 and Description |
---|---|
void |
QuorumCnxManager.addToRecvQueue(QuorumCnxManager.Message msg)
Inserts an element in the
QuorumCnxManager.recvQueue . |
Copyright © 2008–2019 The Apache Software Foundation. All rights reserved.