From 43205c5df1725aaf97db4fac5714c00a91e00c1a Mon Sep 17 00:00:00 2001 From: Ted Ross Date: Thu, 7 Oct 2010 21:30:59 +0000 Subject: Add explicit node-type declaration for receivers. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1005643 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qmf/AgentSession.cpp | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) (limited to 'cpp') diff --git a/cpp/src/qmf/AgentSession.cpp b/cpp/src/qmf/AgentSession.cpp index eca48d6b83..8c93008a69 100644 --- a/cpp/src/qmf/AgentSession.cpp +++ b/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; -- cgit v1.2.1