Class SocketFrameHandlerFactory

java.lang.Object

com.rabbitmq.client.impl.AbstractFrameHandlerFactory

com.rabbitmq.client.impl.SocketFrameHandlerFactory

All Implemented Interfaces:

FrameHandlerFactory

public class SocketFrameHandlerFactory
extends AbstractFrameHandlerFactory

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	shutdownExecutor
private final SocketFactory	socketFactory
private final SslContextFactory	sslContextFactory

Fields inherited from class AbstractFrameHandlerFactory

configurator, connectionTimeout, maxInboundMessageBodySize, ssl

Constructor Summary

Constructors

Constructor	Description
SocketFrameHandlerFactory(int connectionTimeout, SocketFactory socketFactory, SocketConfigurator configurator, boolean ssl)
SocketFrameHandlerFactory(int connectionTimeout, SocketFactory socketFactory, SocketConfigurator configurator, boolean ssl, ExecutorService shutdownExecutor)
SocketFrameHandlerFactory(int connectionTimeout, SocketFactory socketFactory, SocketConfigurator configurator, boolean ssl, ExecutorService shutdownExecutor, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)

Method Summary

Modifier and Type	Method	Description
FrameHandler	create(Address addr, String connectionName)
FrameHandler	create(Socket sock)
protected Socket	createSocket(String connectionName)
private static void	quietTrySocketClose(Socket socket)

Methods inherited from class Object

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

Field Details

socketFactory

private final SocketFactory socketFactory

shutdownExecutor

private final ExecutorService shutdownExecutor

sslContextFactory

private final SslContextFactory sslContextFactory

Constructor Details

SocketFrameHandlerFactory

public SocketFrameHandlerFactory(int connectionTimeout,
 SocketFactory socketFactory,
 SocketConfigurator configurator,
 boolean ssl)

SocketFrameHandlerFactory

public SocketFrameHandlerFactory(int connectionTimeout,
 SocketFactory socketFactory,
 SocketConfigurator configurator,
 boolean ssl,
 ExecutorService shutdownExecutor)

SocketFrameHandlerFactory

public SocketFrameHandlerFactory(int connectionTimeout,
 SocketFactory socketFactory,
 SocketConfigurator configurator,
 boolean ssl,
 ExecutorService shutdownExecutor,
 SslContextFactory sslContextFactory,
 int maxInboundMessageBodySize)

Method Details

create

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

Throws:

IOException

createSocket

protected Socket createSocket(String connectionName)
                       throws IOException

Throws:

IOException

create

public FrameHandler create(Socket sock)
                    throws IOException

Throws:

IOException

quietTrySocketClose

private static void quietTrySocketClose(Socket socket)