summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/cluster
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2011-02-28 15:36:21 +0000
committerGordon Sim <gsim@apache.org>2011-02-28 15:36:21 +0000
commit778c3d4060448014eccb72169c0b281c13f276d2 (patch)
tree0aff0d6441c884f007be3aa63d5f1012e1fdfc0e /qpid/cpp/src/qpid/cluster
parentb657f00b7b05fd6ac36da7e53680b6cd01dd4d35 (diff)
downloadqpid-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.cpp6
-rw-r--r--qpid/cpp/src/qpid/cluster/Connection.h3
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);