org.apache.activemq.transport.stomp
Class StompTransportFactory
java.lang.Object
org.apache.activemq.transport.TransportFactory
org.apache.activemq.transport.tcp.TcpTransportFactory
org.apache.activemq.transport.stomp.StompTransportFactory
- All Implemented Interfaces:
- BrokerServiceAware
public class StompTransportFactory
- extends TcpTransportFactory
- implements BrokerServiceAware
A STOMP transport factory
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
StompTransportFactory
public StompTransportFactory()
getDefaultWireFormatType
protected java.lang.String getDefaultWireFormatType()
- Overrides:
getDefaultWireFormatType
in class TransportFactory
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:
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interface BrokerServiceAware
serverConfigure
public Transport serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
throws java.lang.Exception
- Description copied from class:
TransportFactory
- Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker. The main difference
between this and the configure() method is that the broker does not issue
requests to the client so the ResponseCorrelator is not needed.
- Overrides:
serverConfigure
in class TransportFactory
- Returns:
-
- Throws:
java.lang.Exception
createInactivityMonitor
protected Transport createInactivityMonitor(Transport transport,
WireFormat format)
- Overrides:
createInactivityMonitor
in class TcpTransportFactory
Copyright © 2005-2016. All Rights Reserved.