Package 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:

AmqpSslTransportFactory, AutoSslTransportFactory, 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.

Constructor Summary

Constructors

Constructor	Description
SslTransportFactory()

Method Summary

Modifier and Type	Method	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 SslTransportServer	createSslTransportServer(URI location, SSLServerSocketFactory serverSocketFactory)	Allows subclasses of SslTransportFactory to create custom instances of SslTransportServer.
protected Transport	createTransport(URI location, WireFormat wf)	Overriding to use SslTransports.
SslTransport	createTransport(WireFormat wireFormat, Socket socket, TcpTransport.InitBuffer initBuffer)
TransportServer	doBind(URI location)	Overriding to use SslTransportServer and allow for proper reflection.

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

createInactivityMonitor, createTcpTransport, createTcpTransportServer, createTransport, isUseInactivityMonitor

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

bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, findTransportFactory, 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

createSslTransportServer

protected SslTransportServer createSslTransportServer(URI location,
                                                      SSLServerSocketFactory serverSocketFactory)
                                               throws IOException,
                                                      URISyntaxException

Allows subclasses of SslTransportFactory to create custom instances of SslTransportServer.

Parameters:

location -

serverSocketFactory -

Returns:

a new SslTransportServer initialized from the given location and socket factory.

Throws:

IOException

URISyntaxException

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

createTransport

public SslTransport createTransport(WireFormat wireFormat,
                                    Socket socket,
                                    TcpTransport.InitBuffer initBuffer)
                             throws IOException

Overrides:

createTransport in class TcpTransportFactory

Throws:

IOException