#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.