org.apache.activemq.transport.nio
Class NIOSSLTransport
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.transport.TransportSupport
org.apache.activemq.transport.TransportThreadSupport
org.apache.activemq.transport.tcp.TcpTransport
org.apache.activemq.transport.nio.NIOTransport
org.apache.activemq.transport.nio.NIOSSLTransport
- All Implemented Interfaces:
- java.lang.Runnable, Service, Transport
- Direct Known Subclasses:
- MQTTNIOSSLTransport, StompNIOSSLTransport
public class NIOSSLTransport
- extends NIOTransport
Fields inherited from class org.apache.activemq.transport.tcp.TcpTransport |
buffOut, closeAsync, connectionTimeout, dataIn, dataOut, diffServChosen, dynamicManagement, ioBufferSize, jmxPort, localLocation, logWriterName, minmumWireFormatVersion, remoteLocation, socket, socketBufferSize, socketFactory, soTimeout, startLogging, stoppedLatch, trace, trafficClass, typeOfServiceChosen, useLocalHost, wireFormat |
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransport |
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 |
Methods inherited from class org.apache.activemq.transport.TransportSupport |
asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.activemq.transport.Transport |
asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs |
Methods inherited from interface org.apache.activemq.Service |
start |
needClientAuth
protected boolean needClientAuth
wantClientAuth
protected boolean wantClientAuth
enabledCipherSuites
protected java.lang.String[] enabledCipherSuites
sslContext
protected javax.net.ssl.SSLContext sslContext
sslEngine
protected javax.net.ssl.SSLEngine sslEngine
sslSession
protected javax.net.ssl.SSLSession sslSession
handshakeInProgress
protected boolean handshakeInProgress
status
protected javax.net.ssl.SSLEngineResult.Status status
handshakeStatus
protected javax.net.ssl.SSLEngineResult.HandshakeStatus handshakeStatus
NIOSSLTransport
public NIOSSLTransport(WireFormat wireFormat,
javax.net.SocketFactory socketFactory,
java.net.URI remoteLocation,
java.net.URI localLocation)
throws java.net.UnknownHostException,
java.io.IOException
- Throws:
java.net.UnknownHostException
java.io.IOException
NIOSSLTransport
public NIOSSLTransport(WireFormat wireFormat,
java.net.Socket socket)
throws java.io.IOException
- Throws:
java.io.IOException
setSslContext
public void setSslContext(javax.net.ssl.SSLContext sslContext)
initializeStreams
protected void initializeStreams()
throws java.io.IOException
- Overrides:
initializeStreams
in class NIOTransport
- Throws:
java.io.IOException
finishHandshake
protected void finishHandshake()
throws java.lang.Exception
- Throws:
java.lang.Exception
serviceRead
protected void serviceRead()
- Overrides:
serviceRead
in class NIOTransport
processCommand
protected void processCommand(java.nio.ByteBuffer plain)
throws java.lang.Exception
- Throws:
java.lang.Exception
secureRead
protected int secureRead(java.nio.ByteBuffer plain)
throws java.lang.Exception
- Throws:
java.lang.Exception
doHandshake
protected void doHandshake()
throws java.lang.Exception
- Throws:
java.lang.Exception
doStop
protected void doStop(ServiceStopper stopper)
throws java.lang.Exception
- Overrides:
doStop
in class NIOTransport
- Throws:
java.lang.Exception
isNeedClientAuth
public boolean isNeedClientAuth()
setNeedClientAuth
public void setNeedClientAuth(boolean needClientAuth)
isWantClientAuth
public boolean isWantClientAuth()
setWantClientAuth
public void setWantClientAuth(boolean wantClientAuth)
getEnabledCipherSuites
public java.lang.String[] getEnabledCipherSuites()
setEnabledCipherSuites
public void setEnabledCipherSuites(java.lang.String[] enabledCipherSuites)
Copyright © 2005-2012. All Rights Reserved.