diff options
author | Gordon Sim <gsim@apache.org> | 2011-02-28 15:36:21 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2011-02-28 15:36:21 +0000 |
commit | 778c3d4060448014eccb72169c0b281c13f276d2 (patch) | |
tree | 0aff0d6441c884f007be3aa63d5f1012e1fdfc0e /qpid/cpp/src/qpid/cluster | |
parent | b657f00b7b05fd6ac36da7e53680b6cd01dd4d35 (diff) | |
download | qpid-python-778c3d4060448014eccb72169c0b281c13f276d2.tar.gz |
NO-JIRA: remove some dead code, rename internal method for clarity
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1075381 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/cluster')
-rw-r--r-- | qpid/cpp/src/qpid/cluster/Connection.cpp | 6 | ||||
-rw-r--r-- | qpid/cpp/src/qpid/cluster/Connection.h | 3 |
2 files changed, 1 insertions, 8 deletions
diff --git a/qpid/cpp/src/qpid/cluster/Connection.cpp b/qpid/cpp/src/qpid/cluster/Connection.cpp index 2532adab84..c1304c2b75 100644 --- a/qpid/cpp/src/qpid/cluster/Connection.cpp +++ b/qpid/cpp/src/qpid/cluster/Connection.cpp @@ -614,12 +614,6 @@ void Connection::exchange(const std::string& encoded) { QPID_LOG(debug, cluster << " updated exchange " << ex->getName()); } -void Connection::queue(const std::string& encoded) { - Buffer buf(const_cast<char*>(encoded.data()), encoded.size()); - broker::Queue::shared_ptr q = broker::Queue::decode(cluster.getBroker().getQueues(), buf); - QPID_LOG(debug, cluster << " updated queue " << q->getName()); -} - void Connection::sessionError(uint16_t , const std::string& msg) { // Ignore errors before isOpen(), we're not multicasting yet. if (connection->isOpen()) diff --git a/qpid/cpp/src/qpid/cluster/Connection.h b/qpid/cpp/src/qpid/cluster/Connection.h index b96fa73072..8a9891deb6 100644 --- a/qpid/cpp/src/qpid/cluster/Connection.h +++ b/qpid/cpp/src/qpid/cluster/Connection.h @@ -163,8 +163,7 @@ class Connection : void txEnd(); void accumulatedAck(const framing::SequenceSet&); - // Encoded queue/exchange replication. - void queue(const std::string& encoded); + // Encoded exchange replication. void exchange(const std::string& encoded); void giveReadCredit(int credit); |