|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.MutexTransport
public class MutexTransport
Thread safe Transport Filter that serializes calls to and from the Transport Stack.
Field Summary |
---|
Fields inherited from class org.apache.activemq.transport.TransportFilter |
---|
next, transportListener |
Constructor Summary | |
---|---|
MutexTransport(Transport next)
|
|
MutexTransport(Transport next,
boolean syncOnCommand)
|
Method Summary | |
---|---|
FutureResponse |
asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
boolean |
isSyncOnCommand()
|
void |
onCommand(java.lang.Object command)
called to process a command |
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 |
void |
setSyncOnCommand(boolean syncOnCommand)
|
java.lang.String |
toString()
|
Methods inherited from class org.apache.activemq.transport.TransportFilter |
---|
getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onException, reconnect, setTransportListener, start, stop, transportInterupted, transportResumed, updateURIs |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public MutexTransport(Transport next)
public MutexTransport(Transport next, boolean syncOnCommand)
Method Detail |
---|
public void onCommand(java.lang.Object command)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public FutureResponse asyncRequest(java.lang.Object command, ResponseCallback responseCallback) throws java.io.IOException
Transport
asyncRequest
in interface Transport
asyncRequest
in class TransportFilter
responseCallback
- TODO
java.io.IOException
public void oneway(java.lang.Object command) throws java.io.IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
java.io.IOException
public java.lang.Object request(java.lang.Object command) throws java.io.IOException
Transport
request
in interface Transport
request
in class TransportFilter
java.io.IOException
public java.lang.Object request(java.lang.Object command, int timeout) throws java.io.IOException
Transport
request
in interface Transport
request
in class TransportFilter
java.io.IOException
public java.lang.String toString()
toString
in class TransportFilter
public boolean isSyncOnCommand()
public void setSyncOnCommand(boolean syncOnCommand)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |