org.apache.activemq.transport.nio
Class NIOSSLTransport

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.transport.TransportSupport
          extended by org.apache.activemq.transport.TransportThreadSupport
              extended by org.apache.activemq.transport.tcp.TcpTransport
                  extended by org.apache.activemq.transport.nio.NIOTransport
                      extended by org.apache.activemq.transport.nio.NIOSSLTransport
All Implemented Interfaces:
java.lang.Runnable, Service, Transport
Direct Known Subclasses:
MQTTNIOSSLTransport, StompNIOSSLTransport

public class NIOSSLTransport
extends NIOTransport


Field Summary
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
           
 
Fields inherited from class org.apache.activemq.transport.nio.NIOTransport
channel, currentBuffer, inputBuffer, nextFrameSize, selection
 
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
 
Constructor Summary
NIOSSLTransport(WireFormat wireFormat, java.net.Socket socket)
           
NIOSSLTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation)
           
 
Method Summary
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)
           
 
Methods inherited from class org.apache.activemq.transport.nio.NIOTransport
doStart
 
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.TransportThreadSupport
getStackSize, isDaemon, setDaemon, setStackSize
 
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 org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start
 
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
 

Field Detail

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
Constructor Detail

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
Method Detail

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.