public class NIOSSLTransport extends NIOTransport
TcpTransport.InitBuffer
Modifier and Type | Field and Description |
---|---|
protected String[] |
enabledCipherSuites |
protected String[] |
enabledProtocols |
protected boolean |
handshakeInProgress |
protected SSLEngineResult.HandshakeStatus |
handshakeStatus |
protected CountDownLatch |
initialized |
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, initBuffer, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, receiveCounter, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
NIOSSLTransport(WireFormat wireFormat,
SocketFactory socketFactory,
URI remoteLocation,
URI localLocation) |
NIOSSLTransport(WireFormat wireFormat,
Socket socket,
SSLEngine engine,
TcpTransport.InitBuffer initBuffer,
ByteBuffer inputBuffer) |
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 |
doInit() |
protected void |
doOpenWireInit() |
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) |
void |
serviceRead() |
void |
setEnabledCipherSuites(String[] enabledCipherSuites) |
void |
setEnabledProtocols(String[] enabledProtocols) |
void |
setNeedClientAuth(boolean needClientAuth) |
void |
setSslContext(SSLContext sslContext) |
void |
setWantClientAuth(boolean wantClientAuth) |
readFromBuffer
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, setPeerCertificates, 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
protected final CountDownLatch initialized
public NIOSSLTransport(WireFormat wireFormat, SocketFactory socketFactory, URI remoteLocation, URI localLocation) throws UnknownHostException, IOException
UnknownHostException
IOException
public NIOSSLTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer) throws IOException
IOException
public void setSslContext(SSLContext sslContext)
protected void initializeStreams() throws IOException
initializeStreams
in class NIOTransport
IOException
protected void doOpenWireInit() throws Exception
Exception
protected void finishHandshake() throws Exception
Exception
public 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()
getPeerCertificates
in interface Transport
getPeerCertificates
in class TcpTransport
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 The Apache Software Foundation. All rights reserved.