diff options
Diffstat (limited to 'cpp/lib/client/ClientChannel.cpp')
-rw-r--r-- | cpp/lib/client/ClientChannel.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/cpp/lib/client/ClientChannel.cpp b/cpp/lib/client/ClientChannel.cpp index af26990d8a..d9edb2f390 100644 --- a/cpp/lib/client/ClientChannel.cpp +++ b/cpp/lib/client/ClientChannel.cpp @@ -256,6 +256,16 @@ void Channel::rollback(){ sendAndReceive(frame, method_bodies.tx_rollback_ok); } +void Channel::handleRequest(AMQRequestBody::shared_ptr body) { + // FIXME aconway 2007-01-19: request/response handling. + handleMethod(body); +} + +void Channel::handleResponse(AMQResponseBody::shared_ptr body) { + // FIXME aconway 2007-01-19: request/response handling. + handleMethod(body); +} + void Channel::handleMethod(AMQMethodBody::shared_ptr body){ //channel.flow, channel.close, basic.deliver, basic.return or a response to a synchronous request if(responses.isWaiting()){ |