Uses of Class
com.rabbitmq.client.impl.nio.NioParams
-
Packages that use NioParams 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. -
-
Uses of NioParams in com.rabbitmq.client
Fields in com.rabbitmq.client declared as NioParams Modifier and Type Field Description private NioParams
ConnectionFactory. nioParams
Methods in com.rabbitmq.client that return NioParams Modifier and Type Method Description NioParams
ConnectionFactory. getNioParams()
Retrieve the parameters for NIO mode.Methods in com.rabbitmq.client with parameters of type NioParams Modifier and Type Method Description void
ConnectionFactory. setNioParams(NioParams nioParams)
Sets the parameters when using NIO. -
Uses of NioParams in com.rabbitmq.client.impl.nio
Fields in com.rabbitmq.client.impl.nio declared as NioParams Modifier and Type Field Description private NioParams
NioContext. nioParams
private NioParams
NioLoop. nioParams
(package private) NioParams
SocketChannelFrameHandlerFactory. nioParams
Methods in com.rabbitmq.client.impl.nio that return NioParams Modifier and Type Method 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 createByteBuffer
s.NioParams
NioParams. setConnectionShutdownExecutor(java.util.concurrent.ExecutorService connectionShutdownExecutor)
Set theExecutorService
used for connection shutdown.NioParams
NioParams. setNbIoThreads(int nbIoThreads)
Sets the max number of threads/tasks used for NIO.NioParams
NioParams. setNioExecutor(java.util.concurrent.ExecutorService nioExecutor)
Sets theExecutorService
to use for NIO threads/tasks.NioParams
NioParams. setReadByteBufferSize(int readByteBufferSize)
Sets the size in byte of the readByteBuffer
used in the NIO loop.NioParams
NioParams. setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)
Sets theThreadFactory
to use for NIO threads/tasks.NioParams
NioParams. setWriteByteBufferSize(int writeByteBufferSize)
Sets the size in byte of the writeByteBuffer
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(java.util.function.Function<NioContext,NioQueue> writeQueueFactory)
Set the factory to createNioQueue
s.Constructors in com.rabbitmq.client.impl.nio with parameters of type NioParams Constructor Description NioContext(NioParams nioParams, javax.net.ssl.SSLEngine sslEngine)
NioLoop(NioParams nioParams, NioLoopContext loopContext)
NioLoopContext(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams)
NioParams(NioParams nioParams)
SocketChannelFrameHandlerFactory(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)
SocketChannelFrameHandlerState(java.nio.channels.SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, javax.net.ssl.SSLEngine sslEngine, int maxFramePayloadSize)
-