org.apache.activemq.transport
Class MarshallingTransportFilter

java.lang.Object
  org.apache.activemq.transport.TransportFilter
      org.apache.activemq.transport.MarshallingTransportFilter

All Implemented Interfaces:

Service, Transport, TransportListener

public class MarshallingTransportFilter
extends TransportFilter

Field Summary

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

next, transportListener

Constructor Summary

MarshallingTransportFilter(Transport next, WireFormat localWireFormat, WireFormat remoteWireFormat)

Method Summary

void	onCommand(java.lang.Object command) called to process a command
void	oneway(java.lang.Object command) A one way asynchronous send

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

asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed, updateURIs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MarshallingTransportFilter

public MarshallingTransportFilter(Transport next,
                                  WireFormat localWireFormat,
                                  WireFormat remoteWireFormat)

Method Detail

oneway

public void oneway(java.lang.Object command)
            throws java.io.IOException

Description copied from interface: Transport

A one way asynchronous send

Specified by:

oneway in interface Transport

Overrides:

oneway in class TransportFilter

Throws:

java.io.IOException

onCommand

public void onCommand(java.lang.Object command)

Description copied from interface: TransportListener

called to process a command

Specified by:

onCommand in interface TransportListener

Overrides:

onCommand in class TransportFilter