summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/ha/RemoteBackup.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/ha/RemoteBackup.cpp')
-rw-r--r--cpp/src/qpid/ha/RemoteBackup.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/ha/RemoteBackup.cpp b/cpp/src/qpid/ha/RemoteBackup.cpp
index c37d44fa08..e55d415972 100644
--- a/cpp/src/qpid/ha/RemoteBackup.cpp
+++ b/cpp/src/qpid/ha/RemoteBackup.cpp
@@ -108,13 +108,13 @@ void RemoteBackup::ready(const QueuePtr& q) {
QPID_LOG(debug, logPrefix << "Caught up on queue: " << q->getName() );
}
-// Called via ConfigurationObserver::queueCreate and from catchupQueue
+// Called via BrokerObserver::queueCreate and from catchupQueue
void RemoteBackup::queueCreate(const QueuePtr& q) {
if (replicationTest.getLevel(*q) == ALL)
guards[q].reset(new QueueGuard(*q, brokerInfo));
}
-// Called via ConfigurationObserver
+// Called via BrokerObserver
void RemoteBackup::queueDestroy(const QueuePtr& q) {
catchupQueues.erase(q);
GuardMap::iterator i = guards.find(q);