summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2010-03-23 21:10:31 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2010-03-23 21:10:31 +0000
commitd1178e0c2abe09f41eba0c1f794edd7caf8b8605 (patch)
treeee69bf58957c820938c36345cf18d016574e5526
parentccce021f378b77725c27529a631e93605c283fd4 (diff)
downloadqpid-python-d1178e0c2abe09f41eba0c1f794edd7caf8b8605.tar.gz
bugfix: use null string when no correlation id needed
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qmf-devel0.7a@926783 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/qpid/management/ManagementAgent.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/qpid/cpp/src/qpid/management/ManagementAgent.cpp b/qpid/cpp/src/qpid/management/ManagementAgent.cpp
index 77147b6010..b1802293b7 100644
--- a/qpid/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/qpid/cpp/src/qpid/management/ManagementAgent.cpp
@@ -292,7 +292,7 @@ void ManagementAgent::raiseEvent(const ManagementEvent& event, severity_t severi
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 (void)
}
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 (void)
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 (void)
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(const ObjectId& oid)
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);