Package org.apache.activemq.transport.amqp

Class AmqpNioSslTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

org.apache.activemq.transport.nio.NIOTransportFactory

org.apache.activemq.transport.amqp.AmqpNioTransportFactory

org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory

All Implemented Interfaces:

BrokerServiceAware

public class AmqpNioSslTransportFactory
extends AmqpNioTransportFactory

Field Summary

Fields

Modifier and Type	Field	Description
protected SSLContext	context

Constructor Summary

Constructors

Constructor	Description
AmqpNioSslTransportFactory()

Method Summary

Modifier and Type	Method	Description
protected TcpTransport	createTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation)	Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport instances.
protected TcpTransportServer	createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory)	Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.
TcpTransport	createTransport(WireFormat wireFormat, Socket socket, SSLEngine engine, TcpTransport.InitBuffer initBuffer, ByteBuffer inputBuffer)
TransportServer	doBind(URI location)

Methods inherited from class org.apache.activemq.transport.amqp.AmqpNioTransportFactory

compositeConfigure, createInactivityMonitor, createTransport, getDefaultWireFormatType, serverConfigure, setBrokerService

Methods inherited from class org.apache.activemq.transport.nio.NIOTransportFactory

createServerSocketFactory, createSocketFactory

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

createTransport, isUseInactivityMonitor

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

bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, findTransportFactory, getOption, registerTransportFactory

Methods inherited from class java.lang.Object

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

Field Detail

context

protected SSLContext context

Constructor Detail

AmqpNioSslTransportFactory

public AmqpNioSslTransportFactory()

Method Detail

createTcpTransportServer

protected TcpTransportServer createTcpTransportServer(URI location,
                                                      ServerSocketFactory serverSocketFactory)
                                               throws IOException,
                                                      URISyntaxException

Description copied from class: TcpTransportFactory

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.

Overrides:

createTcpTransportServer in class AmqpNioTransportFactory

Returns:

a new TcpTransportServer instance.

Throws:

IOException

URISyntaxException

createTcpTransport

protected TcpTransport createTcpTransport(WireFormat wf,
                                          SocketFactory socketFactory,
                                          URI location,
                                          URI localLocation)
                                   throws UnknownHostException,
                                          IOException

Description copied from class: TcpTransportFactory

Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport instances.

Overrides:

createTcpTransport in class AmqpNioTransportFactory

Returns:

a new TcpTransport instance connected to the given location.

Throws:

UnknownHostException

IOException

createTransport

public TcpTransport createTransport(WireFormat wireFormat,
                                    Socket socket,
                                    SSLEngine engine,
                                    TcpTransport.InitBuffer initBuffer,
                                    ByteBuffer inputBuffer)
                             throws IOException

Overrides:

createTransport in class TcpTransportFactory

Throws:

IOException

doBind

public TransportServer doBind(URI location)
                       throws IOException

Overrides:

doBind in class TcpTransportFactory

Throws:

IOException