Add explicit node-type declaration for receivers.

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

1 files changed, 6 insertions, 4 deletions

diff --git a/qpid/cpp/src/qmf/AgentSession.cpp b/qpid/cpp/src/qmf/AgentSession.cpp
index eca48d6b83..8c93008a69 100644
--- a/qpid/cpp/src/qmf/AgentSession.cpp
+++ b/qpid/cpp/src/qmf/AgentSession.cpp
@@ -225,6 +225,8 @@ void AgentSessionImpl::open()
         throw QmfException("The session is already open");
     opened = true;
 
+    const string addrArgs(";{create:never,node:{type:topic}}");
+
     // Establish messaging addresses
     setAgentName();
     directBase = "qmf." + domain + ".direct";
@@ -232,14 +234,14 @@ void AgentSessionImpl::open()
 
     // Create AMQP session, receivers, and senders
     session = connection.createSession();
-    Receiver directRx = session.createReceiver(directBase + "/" + agentName);
-    Receiver topicRx = session.createReceiver(topicBase + "/console.#");
+    Receiver directRx = session.createReceiver(directBase + "/" + agentName + addrArgs);
+    Receiver topicRx = session.createReceiver(topicBase + "/console.#" + addrArgs);
 
     directRx.setCapacity(64);
     topicRx.setCapacity(64);
 
-    directSender = session.createSender(directBase + ";{create:never,node:{type:topic}}");
-    topicSender = session.createSender(topicBase + ";{create:never,node:{type:topic}}");
+    directSender = session.createSender(directBase + addrArgs);
+    topicSender = session.createSender(topicBase + addrArgs);
 
     // Start the receiver thread
     threadCanceled = false;