Package com.rabbitmq.client.impl.nio
Class SocketChannelFrameHandlerFactory
java.lang.Object
com.rabbitmq.client.impl.AbstractFrameHandlerFactory
com.rabbitmq.client.impl.nio.SocketChannelFrameHandlerFactory
- All Implemented Interfaces:
FrameHandlerFactory
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final AtomicLong
private static final org.slf4j.Logger
private final List
<NioLoopContext> (package private) final NioParams
private final SslContextFactory
private final Lock
Fields inherited from class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
configurator, connectionTimeout, maxInboundMessageBodySize, ssl
-
Constructor Summary
ConstructorsConstructorDescriptionSocketChannelFrameHandlerFactory
(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize) -
Method Summary
-
Field Details
-
LOGGER
private static final org.slf4j.Logger LOGGER -
nioParams
-
sslContextFactory
-
stateLock
-
globalConnectionCount
-
nioLoopContexts
-
-
Constructor Details
-
SocketChannelFrameHandlerFactory
public SocketChannelFrameHandlerFactory(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)
-
-
Method Details
-
create
- Throws:
IOException
-
lock
void lock() -
unlock
void unlock()
-