summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/UpdateClient.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-03-09 17:03:40 +0000
committerAlan Conway <aconway@apache.org>2009-03-09 17:03:40 +0000
commitfaae42761fe83f083d408d2b4f9e95b7c619122e (patch)
tree21013d3445ce52650c9c1a2e8859dd0d931b0f09 /cpp/src/qpid/cluster/UpdateClient.h
parentbbbd455d8053d3fea713d8f04b0187ac73c72d83 (diff)
downloadqpid-python-faae42761fe83f083d408d2b4f9e95b7c619122e.tar.gz
Fix cluster TTL: replicte expiry information to newcomers.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@751760 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/UpdateClient.h')
-rw-r--r--cpp/src/qpid/cluster/UpdateClient.h5
1 files changed, 3 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/UpdateClient.h b/cpp/src/qpid/cluster/UpdateClient.h
index a0813d0a17..23d061b7e4 100644
--- a/cpp/src/qpid/cluster/UpdateClient.h
+++ b/cpp/src/qpid/cluster/UpdateClient.h
@@ -56,6 +56,7 @@ class Cluster;
class Connection;
class ClusterMap;
class Decoder;
+class ExpiryPolicy;
/**
* A client that updates the contents of a local broker to a remote one using AMQP.
@@ -65,7 +66,7 @@ class UpdateClient : public sys::Runnable {
static const std::string UPDATE; // Name for special update queue and exchange.
UpdateClient(const MemberId& updater, const MemberId& updatee, const Url&,
- broker::Broker& donor, const ClusterMap& map, uint64_t frameId,
+ broker::Broker& donor, const ClusterMap& map, ExpiryPolicy& expiry,
const std::vector<boost::intrusive_ptr<Connection> >&, Decoder&,
const boost::function<void()>& done,
const boost::function<void(const std::exception&)>& fail,
@@ -94,7 +95,7 @@ class UpdateClient : public sys::Runnable {
Url updateeUrl;
broker::Broker& updaterBroker;
ClusterMap map;
- uint64_t frameId;
+ ExpiryPolicy& expiry;
std::vector<boost::intrusive_ptr<Connection> > connections;
Decoder& decoder;
client::Connection connection, shadowConnection;