public class NIOSSLTransport extends NIOTransport
Modifier and Type | Field and Description |
---|---|
protected String[] |
enabledCipherSuites |
protected String[] |
enabledProtocols |
protected boolean |
handshakeInProgress |
protected SSLEngineResult.HandshakeStatus |
handshakeStatus |
protected boolean |
needClientAuth |
protected SSLContext |
sslContext |
protected SSLEngine |
sslEngine |
protected SSLSession |
sslSession |
protected SSLEngineResult.Status |
status |
protected TaskRunnerFactory |
taskRunnerFactory |
protected boolean |
wantClientAuth |
channel, currentBuffer, inputBuffer, nextFrameSize, selection
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
NIOSSLTransport(WireFormat wireFormat,
Socket socket) |
NIOSSLTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
Modifier and Type | Method and Description |
---|---|
void |
doConsume(Object command)
Overriding in order to add the client's certificates to ConnectionInfo Commands.
|
protected void |
doHandshake() |
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
protected void |
finishHandshake() |
String[] |
getEnabledCipherSuites() |
String[] |
getEnabledProtocols() |
X509Certificate[] |
getPeerCertificates() |
protected void |
initializeStreams() |
boolean |
isNeedClientAuth() |
boolean |
isWantClientAuth() |
protected void |
processCommand(ByteBuffer plain) |
protected int |
secureRead(ByteBuffer plain) |
protected void |
serviceRead() |
void |
setEnabledCipherSuites(String[] enabledCipherSuites) |
void |
setEnabledProtocols(String[] enabledProtocols) |
void |
setNeedClientAuth(boolean needClientAuth) |
void |
setSslContext(SSLContext sslContext) |
void |
setWantClientAuth(boolean wantClientAuth) |
closeStreams, connect, doRun, getConnectionTimeout, getDiffServ, getIoBufferSize, getJmxPort, getKeepAlive, getLogWriterName, getMinmumWireFormatVersion, getReceiveCounter, getRemoteAddress, getSocketBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, getTypeOfService, getWireFormat, initialiseSocket, isCloseAsync, isDynamicManagement, isStartLogging, isTrace, isUseLocalHost, narrow, oneway, readCommand, resolveHostName, run, setCloseAsync, setConnectionTimeout, setDiffServ, setDynamicManagement, setIoBufferSize, setJmxPort, setKeepAlive, setLogWriterName, setMinmumWireFormatVersion, setSocketBufferSize, setSocketOptions, setSoLinger, setSoTimeout, setStartLogging, setTcpNoDelay, setTrace, setTypeOfService, setUseLocalHost, stop, toString
getStackSize, isDaemon, setDaemon, setStackSize
asyncRequest, checkStarted, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs
protected boolean needClientAuth
protected boolean wantClientAuth
protected String[] enabledCipherSuites
protected String[] enabledProtocols
protected SSLContext sslContext
protected SSLSession sslSession
protected volatile boolean handshakeInProgress
protected SSLEngineResult.Status status
protected SSLEngineResult.HandshakeStatus handshakeStatus
protected TaskRunnerFactory taskRunnerFactory
public NIOSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostException
IOException
public NIOSSLTransport(WireFormat wireFormat, Socket socket) throws IOException
IOException
public void setSslContext(SSLContext sslContext)
protected void initializeStreams() throws IOException
initializeStreams
in class NIOTransport
IOException
protected void finishHandshake() throws Exception
Exception
protected void serviceRead()
serviceRead
in class NIOTransport
protected void processCommand(ByteBuffer plain) throws Exception
Exception
protected int secureRead(ByteBuffer plain) throws Exception
Exception
protected void doHandshake() throws Exception
Exception
protected void doStart() throws Exception
doStart
in class NIOTransport
Exception
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class NIOTransport
Exception
public void doConsume(Object command)
doConsume
in class TransportSupport
command
- The Command coming in.public X509Certificate[] getPeerCertificates()
public boolean isNeedClientAuth()
public void setNeedClientAuth(boolean needClientAuth)
public boolean isWantClientAuth()
public void setWantClientAuth(boolean wantClientAuth)
public String[] getEnabledCipherSuites()
public void setEnabledCipherSuites(String[] enabledCipherSuites)
public String[] getEnabledProtocols()
public void setEnabledProtocols(String[] enabledProtocols)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.