public class SslClientConnectionFactory extends java.lang.Object implements ClientConnectionFactory
| Modifier and Type | Class and Description |
|---|---|
private class |
SslClientConnectionFactory.HTTPSHandshakeListener |
ClientConnectionFactory.Decorator| Modifier and Type | Field and Description |
|---|---|
private boolean |
_directBuffersForDecryption |
private boolean |
_directBuffersForEncryption |
private boolean |
_requireCloseMessage |
private ByteBufferPool |
byteBufferPool |
private ClientConnectionFactory |
connectionFactory |
private java.util.concurrent.Executor |
executor |
static java.lang.String |
SSL_CONTEXT_FACTORY_CONTEXT_KEY |
static java.lang.String |
SSL_ENGINE_CONTEXT_KEY |
static java.lang.String |
SSL_PEER_HOST_CONTEXT_KEY |
static java.lang.String |
SSL_PEER_PORT_CONTEXT_KEY |
private SslContextFactory |
sslContextFactory |
CONNECTOR_CONTEXT_KEY| Constructor and Description |
|---|
SslClientConnectionFactory(SslContextFactory sslContextFactory,
ByteBufferPool byteBufferPool,
java.util.concurrent.Executor executor,
ClientConnectionFactory connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
Connection |
customize(Connection connection,
java.util.Map<java.lang.String,java.lang.Object> context) |
boolean |
isAllowMissingCloseMessage()
Deprecated.
use
isRequireCloseMessage() instead |
boolean |
isDirectBuffersForDecryption() |
boolean |
isDirectBuffersForEncryption() |
boolean |
isRequireCloseMessage() |
Connection |
newConnection(EndPoint endPoint,
java.util.Map<java.lang.String,java.lang.Object> context) |
protected SslConnection |
newSslConnection(ByteBufferPool byteBufferPool,
java.util.concurrent.Executor executor,
EndPoint endPoint,
javax.net.ssl.SSLEngine engine) |
void |
setAllowMissingCloseMessage(boolean allowMissingCloseMessage)
Deprecated.
use
setRequireCloseMessage(boolean) instead |
void |
setDirectBuffersForDecryption(boolean useDirectBuffers) |
void |
setDirectBuffersForEncryption(boolean useDirectBuffers) |
void |
setRequireCloseMessage(boolean requireCloseMessage) |
public static final java.lang.String SSL_CONTEXT_FACTORY_CONTEXT_KEY
public static final java.lang.String SSL_PEER_HOST_CONTEXT_KEY
public static final java.lang.String SSL_PEER_PORT_CONTEXT_KEY
public static final java.lang.String SSL_ENGINE_CONTEXT_KEY
private final SslContextFactory sslContextFactory
private final ByteBufferPool byteBufferPool
private final java.util.concurrent.Executor executor
private final ClientConnectionFactory connectionFactory
private boolean _directBuffersForEncryption
private boolean _directBuffersForDecryption
private boolean _requireCloseMessage
public SslClientConnectionFactory(SslContextFactory sslContextFactory, ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, ClientConnectionFactory connectionFactory)
public void setDirectBuffersForEncryption(boolean useDirectBuffers)
public void setDirectBuffersForDecryption(boolean useDirectBuffers)
public boolean isDirectBuffersForDecryption()
public boolean isDirectBuffersForEncryption()
@Deprecated public boolean isAllowMissingCloseMessage()
isRequireCloseMessage() insteadclose_notify message@Deprecated public void setAllowMissingCloseMessage(boolean allowMissingCloseMessage)
setRequireCloseMessage(boolean) insteadallowMissingCloseMessage - whether is not required that peers send the TLS close_notify messagepublic boolean isRequireCloseMessage()
close_notify messageSslConnection.isRequireCloseMessage()public void setRequireCloseMessage(boolean requireCloseMessage)
requireCloseMessage - whether peers must send the TLS close_notify messageSslConnection.setRequireCloseMessage(boolean)public Connection newConnection(EndPoint endPoint, java.util.Map<java.lang.String,java.lang.Object> context) throws java.io.IOException
newConnection in interface ClientConnectionFactoryendPoint - the EndPoint to link the newly created connection tocontext - the context data to create the connectionConnectionjava.io.IOException - if the connection cannot be createdprotected SslConnection newSslConnection(ByteBufferPool byteBufferPool, java.util.concurrent.Executor executor, EndPoint endPoint, javax.net.ssl.SSLEngine engine)
public Connection customize(Connection connection, java.util.Map<java.lang.String,java.lang.Object> context)
customize in interface ClientConnectionFactory