diff options
Diffstat (limited to 'qpid/cpp/src/qpid/ha/Backup.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/ha/Backup.cpp | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/ha/Backup.cpp b/qpid/cpp/src/qpid/ha/Backup.cpp index 6e61ed0b46..e5bd0ed4dc 100644 --- a/qpid/cpp/src/qpid/ha/Backup.cpp +++ b/qpid/cpp/src/qpid/ha/Backup.cpp @@ -56,6 +56,7 @@ Backup::Backup(broker::Broker& b, const Settings& s) : s.mechanism, s.username, s.password); assert(result.second); // FIXME aconway 2011-11-23: error handling link = result.first; + link->setUrl(Url(s.brokerUrl)); replicator.reset(new BrokerReplicator(link)); broker.getExchanges().registerExchange(replicator); @@ -63,6 +64,11 @@ Backup::Backup(broker::Broker& b, const Settings& s) : broker.getConnectionObservers().add(excluder); } +void Backup::setUrl(const Url& url) { + // FIXME aconway 2012-01-30: locking? + link->setUrl(url); +} + Backup::~Backup() { broker.getExchanges().destroy(replicator->getName()); broker.getConnectionObservers().remove(excluder); // Allows client connections. |