diff options
Diffstat (limited to 'cpp/lib/client/Connection.cpp')
-rw-r--r-- | cpp/lib/client/Connection.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/cpp/lib/client/Connection.cpp b/cpp/lib/client/Connection.cpp index dd1e372095..1ae317db62 100644 --- a/cpp/lib/client/Connection.cpp +++ b/cpp/lib/client/Connection.cpp @@ -184,6 +184,16 @@ void Connection::handleFrame(AMQFrame* frame){ } } +void Connection::handleRequest(AMQRequestBody::shared_ptr body) { + // FIXME aconway 2007-01-19: request/response handling. + handleMethod(body); +} + +void Connection::handleResponse(AMQResponseBody::shared_ptr body) { + // FIXME aconway 2007-01-19: request/response handling. + handleMethod(body); +} + void Connection::handleMethod(AMQMethodBody::shared_ptr body){ //connection.close, basic.deliver, basic.return or a response to a synchronous request if(responses.isWaiting()){ |