diff options
author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-03-23 21:10:31 +0000 |
---|---|---|
committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-03-23 21:10:31 +0000 |
commit | d1178e0c2abe09f41eba0c1f794edd7caf8b8605 (patch) | |
tree | ee69bf58957c820938c36345cf18d016574e5526 | |
parent | ccce021f378b77725c27529a631e93605c283fd4 (diff) | |
download | qpid-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.cpp | 12 |
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); |