org.apache.activemq.transport
Class MutexTransport
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.MutexTransport
- All Implemented Interfaces:
- Service, Transport, TransportListener
public class MutexTransport
- extends TransportFilter
- Version:
- $Revision$
Method Summary |
FutureResponse |
asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned
in the future. |
void |
oneway(java.lang.Object command)
A one way asynchronous send |
java.lang.Object |
request(java.lang.Object command)
A synchronous request response |
java.lang.Object |
request(java.lang.Object command,
int timeout)
A synchronous request response |
java.lang.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 |
MutexTransport
public MutexTransport(Transport next)
asyncRequest
public FutureResponse asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
throws java.io.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:
java.io.IOException
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
request
public java.lang.Object request(java.lang.Object command)
throws java.io.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:
java.io.IOException
request
public java.lang.Object request(java.lang.Object command,
int timeout)
throws java.io.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:
java.io.IOException
toString
public java.lang.String toString()
- Overrides:
toString
in class TransportFilter
Copyright © 2009 Apache Software Foundation. All Rights Reserved.