You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2010/10/07 23:30:59 UTC
svn commit: r1005643 - /qpid/trunk/qpid/cpp/src/qmf/AgentSession.cpp
Author: tross
Date: Thu Oct 7 21:30:59 2010
New Revision: 1005643
URL: http://svn.apache.org/viewvc?rev=1005643&view=rev
Log:
Add explicit node-type declaration for receivers.
Modified:
qpid/trunk/qpid/cpp/src/qmf/AgentSession.cpp
Modified: qpid/trunk/qpid/cpp/src/qmf/AgentSession.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qmf/AgentSession.cpp?rev=1005643&r1=1005642&r2=1005643&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qmf/AgentSession.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qmf/AgentSession.cpp Thu Oct 7 21:30:59 2010
@@ -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;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org