From faae42761fe83f083d408d2b4f9e95b7c619122e Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Mon, 9 Mar 2009 17:03:40 +0000 Subject: 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 --- cpp/src/qpid/cluster/UpdateClient.h | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/cluster/UpdateClient.h') 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 >&, Decoder&, const boost::function& done, const boost::function& fail, @@ -94,7 +95,7 @@ class UpdateClient : public sys::Runnable { Url updateeUrl; broker::Broker& updaterBroker; ClusterMap map; - uint64_t frameId; + ExpiryPolicy& expiry; std::vector > connections; Decoder& decoder; client::Connection connection, shadowConnection; -- cgit v1.2.1