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.

Field Summary

Fields inherited from class org.apache.activemq.transport.TransportFilter

next, transportListener

Constructor Summary

CommandJoiner(Transport next, OpenWireFormat wireFormat)

Method Summary

void	onCommand(java.lang.Object o) called to process a command
void	stop()
java.lang.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(java.lang.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 java.lang.Exception

Specified by:

stop in interface Service

Overrides:

stop in class TransportFilter

Throws:

java.lang.Exception

See Also:

Service.stop()

toString

public java.lang.String toString()

Overrides:

toString in class TransportFilter