Package com.rabbitmq.client.impl

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 inherited from class com.rabbitmq.client.impl.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)

Methods inherited from class java.lang.Object

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

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