Package | Description |
---|---|
com.rabbitmq.client.impl.nio |
NIO network connector.
|
Modifier and Type | Class and Description |
---|---|
class |
FrameWriteRequest |
class |
HeaderWriteRequest |
Modifier and Type | Field and Description |
---|---|
static WriteRequest |
HeaderWriteRequest.SINGLETON |
Modifier and Type | Method and Description |
---|---|
WriteRequest |
BlockingQueueNioQueue.poll() |
WriteRequest |
NioQueue.poll()
Retrieves and removes the head of this queue,
or returns
null if this queue is empty. |
Modifier and Type | Method and Description |
---|---|
boolean |
BlockingQueueNioQueue.offer(WriteRequest writeRequest) |
boolean |
NioQueue.offer(WriteRequest writeRequest)
Enqueue a frame, block if the queue is full.
|
Constructor and Description |
---|
BlockingQueueNioQueue(BlockingQueue<WriteRequest> delegate,
int writeEnqueuingTimeoutInMs) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.