summaryrefslogtreecommitdiff
path: root/cpp/lib/client/ClientChannel.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/client/ClientChannel.cpp')
-rw-r--r--cpp/lib/client/ClientChannel.cpp10
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()){