org.apache.activemq.transport
Class CommandJoiner

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by 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.


Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
CommandJoiner(Transport next, OpenWireFormat wireFormat)
           
 
Method Summary
 void onCommand(Object o)
          called to process a command
 void stop()
           
 String toString()
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, oneway, onException, reconnect, request, request, setTransportListener, start, transportInterupted, transportResumed, updateURIs
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

CommandJoiner

public CommandJoiner(Transport next,
                     OpenWireFormat wireFormat)
Method Detail

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 © 2005-2012 The Apache Software Foundation. All Rights Reserved.