refactoring:

* separated out the connection level method handling from semantic level (session/channel level should also be separated)
* reduce coupling between Connection and Channel



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@554590 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 2 insertions, 3 deletions

diff --git a/cpp/src/qpid/broker/MessageHandlerImpl.cpp b/cpp/src/qpid/broker/MessageHandlerImpl.cpp
index 22011169a2..bbfcf209ad 100644
--- a/cpp/src/qpid/broker/MessageHandlerImpl.cpp
+++ b/cpp/src/qpid/broker/MessageHandlerImpl.cpp
@@ -123,7 +123,7 @@ MessageHandlerImpl::consume(const MethodContext& context,
                             bool exclusive,
                             const framing::FieldTable& filter )
 {
-    Queue::shared_ptr queue = connection.getQueue(queueName, channel.getId());
+    Queue::shared_ptr queue = getQueue(queueName);
     if(!destination.empty() && channel.exists(destination))
         throw ConnectionException(530, "Consumer tags must be unique");
     string tag = destination;
@@ -142,8 +142,7 @@ MessageHandlerImpl::get( const MethodContext& context,
                          const string& destination,
                          bool noAck )
 {
-    Queue::shared_ptr queue =
-        connection.getQueue(queueName, context.channel->getId());
+    Queue::shared_ptr queue = getQueue(queueName);
     
     if(channel.get(queue, destination, !noAck))
         client.ok(context.getRequestId());