org.apache.activemq.transport.tcp

Class SslTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

org.apache.activemq.transport.tcp.SslTransportFactory

Direct Known Subclasses:

MQTTSslTransportFactory, StompSslTransportFactory

public class SslTransportFactory
extends TcpTransportFactory

An implementation of the TcpTransportFactory using SSL. The major contribution from this class is that it is aware of SslTransportServer and SslTransport classes. All Transports and TransportServers created from this factory will have their needClientAuth option set to false.

Author:

sepandm@gmail.com (Sepand), David Martin Clavo david(dot)martin(dot)clavo(at)gmail.com (logging improvement modifications)

Constructor Summary

Constructors

Constructor and Description
SslTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
Transport	compositeConfigure(Transport transport, WireFormat format, Map options) Overriding to allow for proper configuration through reflection but delegate to get common configuration
protected ServerSocketFactory	createServerSocketFactory() Creates a new SSL ServerSocketFactory.
protected SocketFactory	createSocketFactory() Creates a new SSL SocketFactory.
protected Transport	createTransport(URI location, WireFormat wf) Overriding to use SslTransports.
TransportServer	doBind(URI location) Overriding to use SslTransportServer and allow for proper reflection.
void	setKeyAndTrustManagers(KeyManager[] km, TrustManager[] tm, SecureRandom random) Deprecated. "Do not use anymore... using static initializers like this method only allows the JVM to use 1 SSL configuration per broker."

Methods inherited from class org.apache.activemq.transport.tcp.TcpTransportFactory

createInactivityMonitor, createTcpTransport, createTcpTransportServer, isUseInactivityMonitor

Methods inherited from class org.apache.activemq.transport.TransportFactory

bind, bind, bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, getDefaultWireFormatType, getOption, registerTransportFactory, serverConfigure

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SslTransportFactory

public SslTransportFactory()

Method Detail

doBind

public TransportServer doBind(URI location)
                       throws IOException

Overriding to use SslTransportServer and allow for proper reflection.

Overrides:

doBind in class TcpTransportFactory

Throws:

IOException

compositeConfigure

public Transport compositeConfigure(Transport transport,
                           WireFormat format,
                           Map options)

Overriding to allow for proper configuration through reflection but delegate to get common configuration

Overrides:

compositeConfigure in class TcpTransportFactory

Returns:

createTransport

protected Transport createTransport(URI location,
                        WireFormat wf)
                             throws UnknownHostException,
                                    IOException

Overriding to use SslTransports.

Overrides:

createTransport in class TcpTransportFactory

Throws:

UnknownHostException

IOException

createServerSocketFactory

protected ServerSocketFactory createServerSocketFactory()
                                                 throws IOException

Creates a new SSL ServerSocketFactory. The given factory will use user-provided key and trust managers (if the user provided them).

Overrides:

createServerSocketFactory in class TcpTransportFactory

Returns:

Newly created (Ssl)ServerSocketFactory.

Throws:

IOException

createSocketFactory

protected SocketFactory createSocketFactory()
                                     throws IOException

Creates a new SSL SocketFactory. The given factory will use user-provided key and trust managers (if the user provided them).

Overrides:

createSocketFactory in class TcpTransportFactory

Returns:

Newly created (Ssl)SocketFactory.

Throws:

IOException

setKeyAndTrustManagers

public void setKeyAndTrustManagers(KeyManager[] km,
                          TrustManager[] tm,
                          SecureRandom random)

Deprecated. "Do not use anymore... using static initializers like this method only allows the JVM to use 1 SSL configuration per broker."

Parameters:

km -

tm -

random -

See Also:

SslContext.setCurrentSslContext(SslContext), SslContext.getSSLContext()