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
All Methods Static Methods Instance Methods Concrete Methods 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)
-
-
-
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)
-
-