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

Constructors

Constructor and Description
CommandJoiner(Transport next, OpenWireFormat wireFormat)

Method Summary

Modifier and Type	Method and Description
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