#include <Correlator.h>
Public Types | |
| typedef shared_ptr< AMQResponseBody > | ResponsePtr |
| typedef boost::function< void(ResponsePtr)> | Action |
Public Member Functions | |
| void | request (RequestId id, Action doOnResponse) |
| Note that request with id was sent, record an action to call when a response arrives. | |
| bool | response (shared_ptr< AMQResponseBody >) |
| Note response received, call action for associated request if any. | |
| void | mark (RequestId mark) |
| Note the given execution mark was received, call actions for any requests that are impicitly responded to. | |
THREAD UNSAFE.
| bool qpid::framing::Correlator::response | ( | shared_ptr< AMQResponseBody > | ) |
Note response received, call action for associated request if any.
Return true of some action(s) were executed.
1.4.7