Uses of Class
com.rabbitmq.client.impl.nio.NioParams
Package
Description
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
NIO network connector.
-
Uses of NioParams in com.rabbitmq.client
Modifier and TypeMethodDescriptionConnectionFactory.getNioParams()
Retrieve the parameters for NIO mode.Modifier and TypeMethodDescriptionvoid
ConnectionFactory.setNioParams
(NioParams nioParams) Sets the parameters when using NIO. -
Uses of NioParams in com.rabbitmq.client.impl.nio
Modifier and TypeMethodDescriptionNioParams.enableHostnameVerification()
Enable server hostname verification for TLS connections.NioContext.getNioParams()
NIO params.NioParams.setByteBufferFactory
(ByteBufferFactory byteBufferFactory) Set the factory to createByteBuffer
s.NioParams.setConnectionShutdownExecutor
(ExecutorService connectionShutdownExecutor) Set theExecutorService
used for connection shutdown.NioParams.setNbIoThreads
(int nbIoThreads) Sets the max number of threads/tasks used for NIO.NioParams.setNioExecutor
(ExecutorService nioExecutor) Sets theExecutorService
to use for NIO threads/tasks.NioParams.setReadByteBufferSize
(int readByteBufferSize) Sets the size in byte of the readByteBuffer
used in the NIO loop.NioParams.setThreadFactory
(ThreadFactory threadFactory) Sets theThreadFactory
to use for NIO threads/tasks.NioParams.setWriteByteBufferSize
(int writeByteBufferSize) Sets the size in byte of the writeByteBuffer
used in the NIO loop.NioParams.setWriteEnqueuingTimeoutInMs
(int writeEnqueuingTimeoutInMs) Sets the timeout for queuing outbound frames.NioParams.setWriteQueueCapacity
(int writeQueueCapacity) Set the capacity of the queue used for outbound frames.NioParams.setWriteQueueFactory
(Function<NioContext, NioQueue> writeQueueFactory) Set the factory to createNioQueue
s.ModifierConstructorDescriptionNioLoop
(NioParams nioParams, NioLoopContext loopContext) NioLoopContext
(SocketChannelFrameHandlerFactory socketChannelFrameHandlerFactory, NioParams nioParams) SocketChannelFrameHandlerFactory
(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize) SocketChannelFrameHandlerState
(SocketChannel channel, NioLoopContext nioLoopsState, NioParams nioParams, SSLEngine sslEngine, int maxFramePayloadSize)