diff options
| author | Alan Conway <aconway@apache.org> | 2009-03-09 17:03:40 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-03-09 17:03:40 +0000 |
| commit | faae42761fe83f083d408d2b4f9e95b7c619122e (patch) | |
| tree | 21013d3445ce52650c9c1a2e8859dd0d931b0f09 /cpp/src/qpid/cluster/UpdateClient.h | |
| parent | bbbd455d8053d3fea713d8f04b0187ac73c72d83 (diff) | |
| download | qpid-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.h | 5 |
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; |
