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

Modifier and Type	Field	Description
private java.util.concurrent.ExecutorService	shutdownExecutor
private javax.net.SocketFactory	socketFactory
private SslContextFactory	sslContextFactory

Fields inherited from class com.rabbitmq.client.impl.AbstractFrameHandlerFactory

configurator, connectionTimeout, maxInboundMessageBodySize, ssl

Constructor Summary

Constructors

Constructor	Description
SocketFrameHandlerFactory(int connectionTimeout, javax.net.SocketFactory socketFactory, SocketConfigurator configurator, boolean ssl)
SocketFrameHandlerFactory(int connectionTimeout, javax.net.SocketFactory socketFactory, SocketConfigurator configurator, boolean ssl, java.util.concurrent.ExecutorService shutdownExecutor)
SocketFrameHandlerFactory(int connectionTimeout, javax.net.SocketFactory socketFactory, SocketConfigurator configurator, boolean ssl, java.util.concurrent.ExecutorService shutdownExecutor, SslContextFactory sslContextFactory, int maxInboundMessageBodySize)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

socketFactory

private final javax.net.SocketFactory socketFactory

shutdownExecutor

private final java.util.concurrent.ExecutorService shutdownExecutor

sslContextFactory

private final SslContextFactory sslContextFactory

Constructor Detail

SocketFrameHandlerFactory

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

SocketFrameHandlerFactory

public SocketFrameHandlerFactory(int connectionTimeout,
                                 javax.net.SocketFactory socketFactory,
                                 SocketConfigurator configurator,
                                 boolean ssl,
                                 java.util.concurrent.ExecutorService shutdownExecutor)

SocketFrameHandlerFactory

public SocketFrameHandlerFactory(int connectionTimeout,
                                 javax.net.SocketFactory socketFactory,
                                 SocketConfigurator configurator,
                                 boolean ssl,
                                 java.util.concurrent.ExecutorService shutdownExecutor,
                                 SslContextFactory sslContextFactory,
                                 int maxInboundMessageBodySize)

Method Detail

create

public FrameHandler create(Address addr,
                           java.lang.String connectionName)
                    throws java.io.IOException

Throws:

java.io.IOException

createSocket

protected java.net.Socket createSocket(java.lang.String connectionName)
                                throws java.io.IOException

Throws:

java.io.IOException

create

public FrameHandler create(java.net.Socket sock)
                    throws java.io.IOException

Throws:

java.io.IOException

quietTrySocketClose

private static void quietTrySocketClose(java.net.Socket socket)