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$
Methods inherited from class org.apache.activemq.transport.TransportFilter |
getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, narrow, onCommand, onException, reconnect, setTransportListener, start, stop, transportInterupted, transportResumed |
MutexTransport
public MutexTransport(Transport next)
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 © 2005-2011 Apache Software Foundation. All Rights Reserved.