Package com.rabbitmq.client.impl.nio
Class BlockingQueueNioQueue
- java.lang.Object
- 
- com.rabbitmq.client.impl.nio.BlockingQueueNioQueue
 
- 
- 
Constructor SummaryConstructors Constructor Description BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate, int writeEnqueuingTimeoutInMs)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanisEmpty()Returnstrueif the queue contains no element.booleanoffer(WriteRequest writeRequest)Enqueue a frame, block if the queue is full.WriteRequestpoll()Retrieves and removes the head of this queue, or returnsnullif this queue is empty.intsize()Get the current size of the queue.
 
- 
- 
- 
Constructor Detail- 
BlockingQueueNioQueuepublic BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate, int writeEnqueuingTimeoutInMs) 
 
- 
 - 
Method Detail- 
offerpublic boolean offer(WriteRequest writeRequest) throws InterruptedException Description copied from interface:NioQueueEnqueue a frame, block if the queue is full.- Specified by:
- offerin interface- NioQueue
- Returns:
- Throws:
- InterruptedException
 
 - 
sizepublic int size() Description copied from interface:NioQueueGet the current size of the queue.
 - 
pollpublic WriteRequest poll() Description copied from interface:NioQueueRetrieves and removes the head of this queue, or returnsnullif this queue is empty.
 
- 
 
-