Package com.rabbitmq.client.impl.nio
Class BlockingQueueNioQueue
- java.lang.Object
-
- com.rabbitmq.client.impl.nio.BlockingQueueNioQueue
-
-
Constructor Summary
Constructors Constructor Description BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate, int writeEnqueuingTimeoutInMs)
-
Method Summary
All 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
-
BlockingQueueNioQueue
public BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate, int writeEnqueuingTimeoutInMs)
-
-
Method Detail
-
offer
public boolean offer(WriteRequest writeRequest) throws InterruptedException
Description copied from interface:NioQueueEnqueue a frame, block if the queue is full.- Specified by:
offerin interfaceNioQueue- Returns:
- Throws:
InterruptedException
-
size
public int size()
Description copied from interface:NioQueueGet the current size of the queue.
-
poll
public WriteRequest poll()
Description copied from interface:NioQueueRetrieves and removes the head of this queue, or returnsnullif this queue is empty.
-
-