Package | Description |
---|---|
com.rabbitmq.client |
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
|
com.rabbitmq.client.impl.nio |
NIO network connector.
|
Modifier and Type | Method and Description |
---|---|
NioParams |
ConnectionFactory.getNioParams()
Retrieve the parameters for NIO mode.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionFactory.setNioParams(NioParams nioParams)
Sets the parameters when using NIO.
|
Modifier and Type | Method and Description |
---|---|
NioParams |
NioParams.enableHostnameVerification()
Enable server hostname verification for TLS connections.
|
NioParams |
NioContext.getNioParams()
NIO params.
|
NioParams |
NioParams.setByteBufferFactory(ByteBufferFactory byteBufferFactory)
Set the factory to create
ByteBuffer s. |
NioParams |
NioParams.setConnectionShutdownExecutor(ExecutorService connectionShutdownExecutor)
Set the
ExecutorService used for connection shutdown. |
NioParams |
NioParams.setNbIoThreads(int nbIoThreads)
Sets the max number of threads/tasks used for NIO.
|
NioParams |
NioParams.setNioExecutor(ExecutorService nioExecutor)
Sets the
ExecutorService to use for NIO threads/tasks. |
NioParams |
NioParams.setReadByteBufferSize(int readByteBufferSize)
Sets the size in byte of the read
ByteBuffer used in the NIO loop. |
NioParams |
NioParams.setThreadFactory(ThreadFactory threadFactory)
Sets the
ThreadFactory to use for NIO threads/tasks. |
NioParams |
NioParams.setWriteByteBufferSize(int writeByteBufferSize)
Sets the size in byte of the write
ByteBuffer used in the NIO loop. |
NioParams |
NioParams.setWriteEnqueuingTimeoutInMs(int writeEnqueuingTimeoutInMs)
Sets the timeout for queuing outbound frames.
|
NioParams |
NioParams.setWriteQueueCapacity(int writeQueueCapacity)
Set the capacity of the queue used for outbound frames.
|
NioParams |
NioParams.setWriteQueueFactory(Function<NioContext,NioQueue> writeQueueFactory)
Set the factory to create
NioQueue s. |
Constructor and Description |
---|
NioLoop(NioParams nioParams,
NioLoopContext loopContext) |
NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory,
NioParams nioParams) |
NioParams(NioParams nioParams) |
SocketChannelFrameHandlerFactory(int connectionTimeout,
NioParams nioParams,
boolean ssl,
SslContextFactory sslContextFactory) |
SocketChannelFrameHandlerState(SocketChannel channel,
NioLoopContext nioLoopsState,
NioParams nioParams,
SSLEngine sslEngine) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.