diff options
Diffstat (limited to 'qpid/cpp/src/qpid/ha/Primary.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/ha/Primary.cpp | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/qpid/cpp/src/qpid/ha/Primary.cpp b/qpid/cpp/src/qpid/ha/Primary.cpp index ca92ad77dc..3a9c9a86d9 100644 --- a/qpid/cpp/src/qpid/ha/Primary.cpp +++ b/qpid/cpp/src/qpid/ha/Primary.cpp @@ -259,13 +259,6 @@ void Primary::readyReplica(const ReplicatingSubscription& rs) { if (backup) checkReady(backup); } -void Primary::addReplica(ReplicatingSubscription& rs) { - // Note this is called before the ReplicatingSubscription has been activated - // on the queue. - sys::Mutex::ScopedLock l(lock); - replicas[make_pair(rs.getBrokerInfo().getSystemId(), rs.getQueue())] = &rs; -} - // NOTE: Called with queue registry lock held. void Primary::queueCreate(const QueuePtr& q) { // Set replication argument. |