You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2010/03/23 22:10:32 UTC
svn commit: r926783 -
/qpid/branches/qmf-devel0.7a/qpid/cpp/src/qpid/management/ManagementAgent.cpp
Author: kgiusti
Date: Tue Mar 23 21:10:31 2010
New Revision: 926783
URL: http://svn.apache.org/viewvc?rev=926783&view=rev
Log:
bugfix: use null string when no correlation id needed
Modified:
qpid/branches/qmf-devel0.7a/qpid/cpp/src/qpid/management/ManagementAgent.cpp
Modified: qpid/branches/qmf-devel0.7a/qpid/cpp/src/qpid/management/ManagementAgent.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/qmf-devel0.7a/qpid/cpp/src/qpid/management/ManagementAgent.cpp?rev=926783&r1=926782&r2=926783&view=diff
==============================================================================
--- qpid/branches/qmf-devel0.7a/qpid/cpp/src/qpid/management/ManagementAgent.cpp (original)
+++ qpid/branches/qmf-devel0.7a/qpid/cpp/src/qpid/management/ManagementAgent.cpp Tue Mar 23 21:10:31 2010
@@ -292,7 +292,7 @@ void ManagementAgent::raiseEvent(const M
content.encode();
- sendBuffer(msg.getContent(), 0, headers, mExchange,
+ sendBuffer(msg.getContent(), "", headers, mExchange,
"console.event.1.0." + event.getPackageName() + "." + event.getEventName());
QPID_LOG(trace, "SEND raiseEvent class=" << event.getPackageName() << "." << event.getEventName());
}
@@ -574,8 +574,8 @@ void ManagementAgent::periodicProcessing
}
content.encode();
- const std::string &str = m.getContent();
- if (str.length()) {
+ const std::string &body = m.getContent();
+ if (body.length()) {
stringstream key;
::qpid::messaging::Variant::Map headers;
key << "console.obj.1.0." << baseObject->getPackageName() << "." << baseObject->getClassName();
@@ -585,7 +585,7 @@ void ManagementAgent::periodicProcessing
headers["qmf.content"] = "_data";
headers["qmf.agent"] = std::string(agentName);
- sendBuffer(str, 0, headers, mExchange, key.str());
+ sendBuffer(body, "", headers, mExchange, key.str());
QPID_LOG(trace, "SEND Multicast ContentInd to=" << key.str() << " props=" << pcount << " stats=" << scount);
}
}
@@ -628,7 +628,7 @@ void ManagementAgent::periodicProcessing
stringstream key;
key << "console.obj.1.0." << (*cdIter)->getPackageName() << "." << (*cdIter)->getClassName();
- sendBuffer(m.getContent(), 0, headers, mExchange, key.str());
+ sendBuffer(m.getContent(), "", headers, mExchange, key.str());
QPID_LOG(trace, "SEND ContentInd for deleted object to=" << key.str());
}
}
@@ -689,7 +689,7 @@ void ManagementAgent::deleteObjectNowLH(
headers["qmf.content"] = "_data";
headers["qmf.agent"] = std::string(agentName);
- sendBuffer(m.getContent(), 0, headers, mExchange, key.str());
+ sendBuffer(m.getContent(), "", headers, mExchange, key.str());
QPID_LOG(trace, "SEND Immediate(delete) ContentInd to=" << key.str());
managementObjects.erase(oid);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org