org.apache.activemq.transport.stomp
Class StompNIOTransportFactory

java.lang.Object
  extended by org.apache.activemq.transport.TransportFactory
      extended by org.apache.activemq.transport.tcp.TcpTransportFactory
          extended by org.apache.activemq.transport.nio.NIOTransportFactory
              extended by org.apache.activemq.transport.stomp.StompNIOTransportFactory
All Implemented Interfaces:
BrokerServiceAware

public class StompNIOTransportFactory
extends NIOTransportFactory
implements BrokerServiceAware

A STOMP over NIO transport factory


Constructor Summary
StompNIOTransportFactory()
           
 
Method Summary
 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  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  java.lang.String getDefaultWireFormatType()
           
protected  boolean isUseInactivityMonitor(Transport transport)
          Returns true if the inactivity monitor should be used on the transport
 void setBrokerService(BrokerService brokerService)
           
 
Methods inherited from class org.apache.activemq.transport.nio.NIOTransportFactory
createServerSocketFactory, createSocketFactory
 
Methods inherited from class org.apache.activemq.transport.tcp.TcpTransportFactory
createTransport, doBind
 
Methods inherited from class org.apache.activemq.transport.TransportFactory
bind, bind, bind, compositeConnect, compositeConnect, configure, connect, connect, createWireFormat, createWireFormatFactory, doCompositeConnect, doCompositeConnect, doConnect, doConnect, getOption, registerTransportFactory, serverConfigure
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StompNIOTransportFactory

public StompNIOTransportFactory()
Method Detail

getDefaultWireFormatType

protected java.lang.String getDefaultWireFormatType()
Overrides:
getDefaultWireFormatType in class TransportFactory

createTcpTransportServer

protected TcpTransportServer createTcpTransportServer(java.net.URI location,
                                                      javax.net.ServerSocketFactory serverSocketFactory)
                                               throws java.io.IOException,
                                                      java.net.URISyntaxException
Description copied from class: TcpTransportFactory
Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.

Overrides:
createTcpTransportServer in class NIOTransportFactory
Returns:
Throws:
java.io.IOException
java.net.URISyntaxException

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
Description copied from class: TcpTransportFactory
Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.

Overrides:
createTcpTransport in class NIOTransportFactory
Returns:
Throws:
java.net.UnknownHostException
java.io.IOException

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 TcpTransportFactory
Returns:

isUseInactivityMonitor

protected boolean isUseInactivityMonitor(Transport transport)
Description copied from class: TcpTransportFactory
Returns true if the inactivity monitor should be used on the transport

Overrides:
isUseInactivityMonitor in class TcpTransportFactory

setBrokerService

public void setBrokerService(BrokerService brokerService)
Specified by:
setBrokerService in interface BrokerServiceAware


Copyright © 2005-2012. All Rights Reserved.