org.apache.activemq.transport
Class MutexTransport

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.MutexTransport
All Implemented Interfaces:
Service, Transport, TransportListener

public class MutexTransport
extends TransportFilter

Version:
$Revision$

Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
MutexTransport(Transport next)
           
 
Method Summary
 FutureResponse asyncRequest(Object command, ResponseCallback responseCallback)
          An asynchronous request response where the Receipt will be returned in the future.
 void oneway(Object command)
          A one way asynchronous send
 Object request(Object command)
          A synchronous request response
 Object request(Object command, int timeout)
          A synchronous request response
 String toString()
           
 
Methods inherited from class org.apache.activemq.transport.TransportFilter
getNext, getRemoteAddress, getTransportListener, narrow, onCommand, onException, setTransportListener, start, stop, transportInterupted, transportResumed
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MutexTransport

public MutexTransport(Transport next)
Method Detail

asyncRequest

public FutureResponse asyncRequest(Object command,
                                   ResponseCallback responseCallback)
                            throws IOException
Description copied from interface: Transport
An asynchronous request response where the Receipt will be returned in the future. If responseCallback is not null, then it will be called when the response has been completed.

Specified by:
asyncRequest in interface Transport
Overrides:
asyncRequest in class TransportFilter
responseCallback - TODO
Returns:
the FutureResponse
Throws:
IOException

oneway

public void oneway(Object command)
            throws IOException
Description copied from interface: Transport
A one way asynchronous send

Specified by:
oneway in interface Transport
Overrides:
oneway in class TransportFilter
Throws:
IOException

request

public Object request(Object command)
               throws IOException
Description copied from interface: Transport
A synchronous request response

Specified by:
request in interface Transport
Overrides:
request in class TransportFilter
Returns:
the response
Throws:
IOException

request

public Object request(Object command,
                      int timeout)
               throws IOException
Description copied from interface: Transport
A synchronous request response

Specified by:
request in interface Transport
Overrides:
request in class TransportFilter
Returns:
the repsonse or null if timeout
Throws:
IOException

toString

public String toString()
Overrides:
toString in class TransportFilter


Copyright © 2011 Apache Software Foundation. All Rights Reserved.