|
||||||||||
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.ResponseCorrelator
public class ResponseCorrelator
Adds the incrementing sequence number to commands along with performing the corelation of responses to requests to create a blocking request-response semantics.
Field Summary |
---|
Fields inherited from class org.apache.activemq.transport.TransportFilter |
---|
next, transportListener |
Constructor Summary | |
---|---|
ResponseCorrelator(Transport next)
|
|
ResponseCorrelator(Transport next,
IntSequenceGenerator sequenceGenerator)
|
Method Summary | |
---|---|
FutureResponse |
asyncRequest(java.lang.Object o,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
IntSequenceGenerator |
getSequenceGenerator()
|
void |
onCommand(java.lang.Object o)
called to process a command |
void |
oneway(java.lang.Object o)
A one way asynchronous send |
void |
onException(java.io.IOException error)
If an async exception occurs, then assume no responses will arrive for any of current requests. |
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, setTransportListener, start, stop, transportInterupted, transportResumed |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public ResponseCorrelator(Transport next)
public ResponseCorrelator(Transport next, IntSequenceGenerator sequenceGenerator)
Method Detail |
---|
public void oneway(java.lang.Object o) throws java.io.IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
java.io.IOException
public FutureResponse asyncRequest(java.lang.Object o, ResponseCallback responseCallback) throws java.io.IOException
Transport
asyncRequest
in interface Transport
asyncRequest
in class TransportFilter
responseCallback
- TODO
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 void onCommand(java.lang.Object o)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void onException(java.io.IOException error)
onException
in interface TransportListener
onException
in class TransportFilter
public IntSequenceGenerator getSequenceGenerator()
public java.lang.String toString()
toString
in class TransportFilter
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |