public class SslTransport extends TcpTransport implements SecuredSession
Modifier and Type | Class and Description |
---|---|
class |
SslTransport.SSLChannel |
ServiceBase.STARTING, ServiceBase.State, ServiceBase.STOPPING
blockingExecutor, channel, codec, dispatchQueue, drainOutboundSource, IPTOS_LOWCOST, IPTOS_LOWDELAY, IPTOS_RELIABILITY, IPTOS_THROUGHPUT, listener, localLocation, rateLimitingChannel, remoteLocation, socketState, useLocalHost, yieldSource
_serviceState, CREATED, STARTED, STOPPED
Constructor and Description |
---|
SslTransport() |
Modifier and Type | Method and Description |
---|---|
void |
connected(SocketChannel channel) |
void |
connecting(URI remoteLocation,
URI localLocation) |
static SslTransport |
createTransport(URI uri)
Allows subclasses of TcpTransportFactory to create custom instances of
TcpTransport.
|
void |
drainInbound() |
void |
flush()
Forces a flush of any output buffers.
|
String |
getClientAuth() |
String |
getDisabledCypherSuites() |
String |
getEnabledCypherSuites() |
X509Certificate[] |
getPeerX509Certificates()
Gets the X509Certificate associated withe the peer.
|
ReadableByteChannel |
getReadChannel() |
SSLSession |
getSSLSession() |
WritableByteChannel |
getWriteChannel() |
void |
handshake() |
protected void |
initializeChannel() |
protected void |
onConnected() |
static String |
protocol(String scheme)
Maps uri schemes to a protocol algorithm names.
|
void |
setClientAuth(String clientAuth) |
void |
setDisabledCypherSuites(String disabledCypherSuites) |
void |
setEnabledCypherSuites(String enabledCypherSuites) |
void |
setSSLContext(SSLContext ctx) |
protected boolean |
transportFlush() |
_start, _stop, full, getBlockingExecutor, getDispatchQueue, getLocalAddress, getLocalHost, getMaxReadRate, getMaxWriteRate, getProtocolCodec, getReceiveBufferSize, getRemoteAddress, getSendBufferSize, getSocketChannel, getTrafficClass, getTransportListener, initializeCodec, isClosed, isCloseOnCancel, isConnected, isKeepAlive, isUseLocalHost, offer, onTransportFailure, resolveHostName, resumeRead, resumeWrite, setBlockingExecutor, setCloseOnCancel, setDispatchQueue, setKeepAlive, setMaxReadRate, setMaxWriteRate, setProtocolCodec, setReceiveBufferSize, setSendBufferSize, setTrafficClass, setTransportListener, setUseLocalHost, suspendRead, suspendWrite
getServiceState, start, start, stop, stop
public SslTransport()
public static String protocol(String scheme)
public void setSSLContext(SSLContext ctx)
public static SslTransport createTransport(URI uri) throws Exception
Exception
public SSLSession getSSLSession()
public X509Certificate[] getPeerX509Certificates()
SecuredSession
getPeerX509Certificates
in interface SecuredSession
public void connecting(URI remoteLocation, URI localLocation) throws Exception
connecting
in class TcpTransport
Exception
public void connected(SocketChannel channel) throws Exception
connected
in class TcpTransport
Exception
protected void initializeChannel() throws Exception
initializeChannel
in class TcpTransport
Exception
protected void onConnected() throws IOException
onConnected
in class TcpTransport
IOException
public void flush()
Transport
flush
in interface Transport
flush
in class TcpTransport
public void drainInbound()
drainInbound
in interface Transport
drainInbound
in class TcpTransport
protected boolean transportFlush() throws IOException
transportFlush
in class TcpTransport
IOException
public void handshake()
public ReadableByteChannel getReadChannel()
getReadChannel
in interface Transport
getReadChannel
in class TcpTransport
public WritableByteChannel getWriteChannel()
getWriteChannel
in interface Transport
getWriteChannel
in class TcpTransport
public String getClientAuth()
public void setClientAuth(String clientAuth)
public String getDisabledCypherSuites()
public String getEnabledCypherSuites()
public void setDisabledCypherSuites(String disabledCypherSuites)
public void setEnabledCypherSuites(String enabledCypherSuites)
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.