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 final AtomicLong	globalConnectionCount
private static final org.slf4j.Logger	LOGGER
private final List<NioLoopContext>	nioLoopContexts
(package private) final NioParams	nioParams
private final SslContextFactory	sslContextFactory
private final Lock	stateLock

Fields inherited from class AbstractFrameHandlerFactory

configurator, connectionTimeout, maxInboundMessageBodySize, ssl

Constructor Summary

Constructors

Constructor	Description
SocketChannelFrameHandlerFactory(int connectionTimeout, NioParams nioParams, boolean ssl, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)

Method Summary

Modifier and Type	Method	Description
FrameHandler	create(Address addr, String connectionName)
(package private) void	lock()
(package private) void	unlock()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

nioParams

final NioParams nioParams

sslContextFactory

private final SslContextFactory sslContextFactory

stateLock

private final Lock stateLock

globalConnectionCount

private final AtomicLong globalConnectionCount

nioLoopContexts

private final List<NioLoopContext> nioLoopContexts

Constructor Details

SocketChannelFrameHandlerFactory

public SocketChannelFrameHandlerFactory(int connectionTimeout,
 NioParams nioParams,
 boolean ssl,
 SslContextFactory sslContextFactory,
 int maxInboundMessageBodySize)

Method Details

create

public FrameHandler create(Address addr,
 String connectionName)
                    throws IOException

Throws:

IOException

lock

void lock()

unlock

void unlock()