org.apache.activemq.transport
Class CommandJoiner
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.CommandJoiner
- All Implemented Interfaces:
- Service, Transport, TransportListener
public class CommandJoiner
- extends TransportFilter
Joins together of partial commands which were split into individual chunks of
data.
- Version:
- $Revision: 464110 $
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getRemoteAddress, getTransportListener, narrow, oneway, onException, request, request, setTransportListener, start, transportInterupted, transportResumed |
CommandJoiner
public CommandJoiner(Transport next,
OpenWireFormat wireFormat)
onCommand
public void onCommand(Object o)
- Description copied from interface:
TransportListener
- called to process a command
- Specified by:
onCommand
in interface TransportListener
- Overrides:
onCommand
in class TransportFilter
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class TransportFilter
- Throws:
Exception
- See Also:
Service.stop()
toString
public String toString()
- Overrides:
toString
in class TransportFilter
Copyright © 2011 Apache Software Foundation. All Rights Reserved.