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
public class SocketChannelFrameHandlerFactory extends AbstractFrameHandlerFactory
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.atomic.AtomicLong
globalConnectionCount
private static org.slf4j.Logger
LOGGER
private java.util.List<NioLoopContext>
nioLoopContexts
(package private) NioParams
nioParams
private SslContextFactory
sslContextFactory
private java.util.concurrent.locks.Lock
stateLock
-
Fields inherited from class com.rabbitmq.client.impl.AbstractFrameHandlerFactory
configurator, connectionTimeout, maxInboundMessageBodySize, ssl
-
-
Constructor Summary
Constructors Constructor Description SocketChannelFrameHandlerFactory(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FrameHandler
create(Address addr, java.lang.String connectionName)
(package private) void
lock()
(package private) void
unlock()
-
-
-
Field Detail
-
LOGGER
private static final org.slf4j.Logger LOGGER
-
nioParams
final NioParams nioParams
-
sslContextFactory
private final SslContextFactory sslContextFactory
-
stateLock
private final java.util.concurrent.locks.Lock stateLock
-
globalConnectionCount
private final java.util.concurrent.atomic.AtomicLong globalConnectionCount
-
nioLoopContexts
private final java.util.List<NioLoopContext> nioLoopContexts
-
-
Constructor Detail
-
SocketChannelFrameHandlerFactory
public SocketChannelFrameHandlerFactory(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)
-
-
Method Detail
-
create
public FrameHandler create(Address addr, java.lang.String connectionName) throws java.io.IOException
- Throws:
java.io.IOException
-
lock
void lock()
-
unlock
void unlock()
-
-