org.apache.activemq.transport.tcp

Class TcpTransportFactory

java.lang.Object

org.apache.activemq.transport.TransportFactory

org.apache.activemq.transport.tcp.TcpTransportFactory

Direct Known Subclasses:

MQTTTransportFactory, NIOTransportFactory, SslTransportFactory, StompTransportFactory

public class TcpTransportFactory
extends TransportFactory

Author:

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

Constructor Summary

Constructors

Constructor and Description
TcpTransportFactory()

Method Summary

Methods

Modifier and Type	Method and Description
Transport	compositeConfigure(Transport transport, WireFormat format, java.util.Map options) Similar to configure(...) but this avoid adding in the MutexTransport and ResponseCorrelator transport layers so that the resulting transport can more efficiently be used as part of a composite transport.
protected Transport	createInactivityMonitor(Transport transport, WireFormat format)
protected javax.net.ServerSocketFactory	createServerSocketFactory()
protected javax.net.SocketFactory	createSocketFactory()
protected TcpTransport	createTcpTransport(WireFormat wf, javax.net.SocketFactory socketFactory, java.net.URI location, java.net.URI localLocation) Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.
protected TcpTransportServer	createTcpTransportServer(java.net.URI location, javax.net.ServerSocketFactory serverSocketFactory) Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.
protected Transport	createTransport(java.net.URI location, WireFormat wf) Factory method to create a new transport
TransportServer	doBind(java.net.URI location)
protected boolean	isUseInactivityMonitor(Transport transport) Returns true if the inactivity monitor should be used on the transport

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

TcpTransportFactory

public TcpTransportFactory()

Method Detail

doBind

public TransportServer doBind(java.net.URI location)
                       throws java.io.IOException

Specified by:

doBind in class TransportFactory

Throws:

java.io.IOException

createTcpTransportServer

protected TcpTransportServer createTcpTransportServer(java.net.URI location,
                                          javax.net.ServerSocketFactory serverSocketFactory)
                                               throws java.io.IOException,
                                                      java.net.URISyntaxException

Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.

Parameters:

location -

serverSocketFactory -

Returns:

Throws:

java.io.IOException

java.net.URISyntaxException

compositeConfigure

public Transport compositeConfigure(Transport transport,
                           WireFormat format,
                           java.util.Map options)

Description copied from class: TransportFactory

Similar to configure(...) but this avoid adding in the MutexTransport and ResponseCorrelator transport layers so that the resulting transport can more efficiently be used as part of a composite transport.

Overrides:

compositeConfigure in class TransportFactory

Returns:

isUseInactivityMonitor

protected boolean isUseInactivityMonitor(Transport transport)

Returns true if the inactivity monitor should be used on the transport

createTransport

protected Transport createTransport(java.net.URI location,
                        WireFormat wf)
                             throws java.net.UnknownHostException,
                                    java.io.IOException

Description copied from class: TransportFactory

Factory method to create a new transport

Overrides:

createTransport in class TransportFactory

Throws:

java.net.UnknownHostException

java.io.IOException

createTcpTransport

protected TcpTransport createTcpTransport(WireFormat wf,
                              javax.net.SocketFactory socketFactory,
                              java.net.URI location,
                              java.net.URI localLocation)
                                   throws java.net.UnknownHostException,
                                          java.io.IOException

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

Parameters:

location -

wf -

socketFactory -

localLocation -

Returns:

Throws:

java.net.UnknownHostException

java.io.IOException

createServerSocketFactory

protected javax.net.ServerSocketFactory createServerSocketFactory()
                                                           throws java.io.IOException

Throws:

java.io.IOException

createSocketFactory

protected javax.net.SocketFactory createSocketFactory()
                                               throws java.io.IOException

Throws:

java.io.IOException

createInactivityMonitor

protected Transport createInactivityMonitor(Transport transport,
                                WireFormat format)