diff options
Diffstat (limited to 'cpp/src/qpid/cluster/Connection.cpp')
| -rw-r--r-- | cpp/src/qpid/cluster/Connection.cpp | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Connection.cpp b/cpp/src/qpid/cluster/Connection.cpp index 5faa184e30..3ce2b3f376 100644 --- a/cpp/src/qpid/cluster/Connection.cpp +++ b/cpp/src/qpid/cluster/Connection.cpp @@ -197,7 +197,6 @@ struct GiveReadCreditOnExit { void Connection::deliverDoOutput(uint32_t limit) { output.deliverDoOutput(limit); - cluster.debugSnapshot("deliver-do-output", this); } // Called in delivery thread, in cluster order. @@ -532,5 +531,14 @@ void Connection::managementSetupState(uint64_t objectNum, uint16_t bootSequence) agent->setBootSequence(bootSequence); } +void Connection::managementAgents(const std::string& data) { + management::ManagementAgent* agent = cluster.getBroker().getManagementAgent(); + if (!agent) + throw Exception(QPID_MSG("Management agents update but no management agent.")); + framing::Buffer buf(const_cast<char*>(data.data()), data.size()); + agent->importAgents(buf); + QPID_LOG(debug, cluster << " updated management agents"); +} + }} // Namespace qpid::cluster |