org.apache.activemq.transport.nio
public class NIOSSLTransport extends NIOTransport
Modifier and Type | Field and Description |
---|---|
protected java.lang.String[] |
enabledCipherSuites |
protected boolean |
handshakeInProgress |
protected javax.net.ssl.SSLEngineResult.HandshakeStatus |
handshakeStatus |
protected boolean |
needClientAuth |
protected javax.net.ssl.SSLContext |
sslContext |
protected javax.net.ssl.SSLEngine |
sslEngine |
protected javax.net.ssl.SSLSession |
sslSession |
protected javax.net.ssl.SSLEngineResult.Status |
status |
protected boolean |
wantClientAuth |
channel, currentBuffer, inputBuffer, nextFrameSize, selection
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat
Constructor and Description |
---|
NIOSSLTransport(WireFormat wireFormat,
java.net.Socket socket) |
NIOSSLTransport(WireFormat wireFormat,
javax.net.SocketFactory socketFactory,
java.net.URI remoteLocation,
java.net.URI localLocation) |
Modifier and Type | Method and Description |
---|---|
protected void |
doHandshake() |
protected void |
doStop(ServiceStopper stopper) |
protected void |
finishHandshake() |
java.lang.String[] |
getEnabledCipherSuites() |
protected void |
initializeStreams() |
boolean |
isNeedClientAuth() |
boolean |
isWantClientAuth() |
protected void |
processCommand(java.nio.ByteBuffer plain) |
protected int |
secureRead(java.nio.ByteBuffer plain) |
protected void |
serviceRead() |
void |
setEnabledCipherSuites(java.lang.String[] enabledCipherSuites) |
void |
setNeedClientAuth(boolean needClientAuth) |
void |
setSslContext(javax.net.ssl.SSLContext sslContext) |
void |
setWantClientAuth(boolean wantClientAuth) |
doStart
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, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs
addServiceListener, dispose, isStarted, isStopped, isStopping, 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 java.lang.String[] enabledCipherSuites
protected javax.net.ssl.SSLContext sslContext
protected javax.net.ssl.SSLEngine sslEngine
protected javax.net.ssl.SSLSession sslSession
protected boolean handshakeInProgress
protected javax.net.ssl.SSLEngineResult.Status status
protected javax.net.ssl.SSLEngineResult.HandshakeStatus handshakeStatus
public NIOSSLTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation) throws java.net.UnknownHostException, java.io.IOException
java.net.UnknownHostException
java.io.IOException
public NIOSSLTransport(WireFormat wireFormat, java.net.Socket socket) throws java.io.IOException
java.io.IOException
public void setSslContext(javax.net.ssl.SSLContext sslContext)
protected void initializeStreams() throws java.io.IOException
initializeStreams
in class NIOTransport
java.io.IOException
protected void finishHandshake() throws java.lang.Exception
java.lang.Exception
protected void serviceRead()
serviceRead
in class NIOTransport
protected void processCommand(java.nio.ByteBuffer plain) throws java.lang.Exception
java.lang.Exception
protected int secureRead(java.nio.ByteBuffer plain) throws java.lang.Exception
java.lang.Exception
protected void doHandshake() throws java.lang.Exception
java.lang.Exception
protected void doStop(ServiceStopper stopper) throws java.lang.Exception
doStop
in class NIOTransport
java.lang.Exception
public boolean isNeedClientAuth()
public void setNeedClientAuth(boolean needClientAuth)
public boolean isWantClientAuth()
public void setWantClientAuth(boolean wantClientAuth)
public java.lang.String[] getEnabledCipherSuites()
public void setEnabledCipherSuites(java.lang.String[] enabledCipherSuites)
Copyright © 2005-2014. All Rights Reserved.