org.apache.activemq.transport.tcp
Class TcpTransportFactory

java.lang.Object
  extended by org.apache.activemq.transport.TransportFactory
      extended by org.apache.activemq.transport.tcp.TcpTransportFactory
Direct Known Subclasses:
AmqpTransportFactory, MQTTTransportFactory, NIOTransportFactory, SslTransportFactory, StompTransportFactory, XmppTransportFactory

public class TcpTransportFactory
extends TransportFactory

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

Constructor Summary
TcpTransportFactory()
           
 
Method Summary
 Transport compositeConfigure(Transport transport, WireFormat format, 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  ServerSocketFactory createServerSocketFactory()
           
protected  SocketFactory createSocketFactory()
           
protected  TcpTransport createTcpTransport(WireFormat wf, SocketFactory socketFactory, URI location, URI localLocation)
          Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.
protected  TcpTransportServer createTcpTransportServer(URI location, ServerSocketFactory serverSocketFactory)
          Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.
protected  Transport createTransport(URI location, WireFormat wf)
          Factory method to create a new transport
 TransportServer doBind(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, 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

TcpTransportFactory

public TcpTransportFactory()
Method Detail

doBind

public TransportServer doBind(URI location)
                       throws IOException
Specified by:
doBind in class TransportFactory
Throws:
IOException

createTcpTransportServer

protected TcpTransportServer createTcpTransportServer(URI location,
                                                      ServerSocketFactory serverSocketFactory)
                                               throws IOException,
                                                      URISyntaxException
Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.

Parameters:
location -
serverSocketFactory -
Returns:
Throws:
IOException
URISyntaxException

compositeConfigure

public Transport compositeConfigure(Transport transport,
                                    WireFormat format,
                                    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(URI location,
                                    WireFormat wf)
                             throws UnknownHostException,
                                    IOException
Description copied from class: TransportFactory
Factory method to create a new transport

Overrides:
createTransport in class TransportFactory
Throws:
UnknownHostException
IOException

createTcpTransport

protected TcpTransport createTcpTransport(WireFormat wf,
                                          SocketFactory socketFactory,
                                          URI location,
                                          URI localLocation)
                                   throws UnknownHostException,
                                          IOException
Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.

Parameters:
location -
wf -
socketFactory -
localLocation -
Returns:
Throws:
UnknownHostException
IOException

createServerSocketFactory

protected ServerSocketFactory createServerSocketFactory()
                                                 throws IOException
Throws:
IOException

createSocketFactory

protected SocketFactory createSocketFactory()
                                     throws IOException
Throws:
IOException

createInactivityMonitor

protected Transport createInactivityMonitor(Transport transport,
                                            WireFormat format)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.