1 files changed, 5 insertions, 3 deletions
diff --git a/cpp/src/qpid/cluster/UpdateClient.h b/cpp/src/qpid/cluster/UpdateClient.h
index d6b821904f..a0813d0a17 100644
--- a/cpp/src/qpid/cluster/UpdateClient.h
+++ b/cpp/src/qpid/cluster/UpdateClient.h
@@ -46,6 +46,7 @@ class SessionHandler;
 class DeliveryRecord;
 class SessionState;
 class SemanticState;
+class Decoder;
 
 } // namespace broker
 
@@ -54,6 +55,7 @@ namespace cluster {
 class Cluster;
 class Connection;
 class ClusterMap;
+class Decoder;
 
 /**
  * A client that updates the contents of a local broker to a remote one using AMQP.
@@ -63,8 +65,8 @@ 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 eventId, uint64_t frameId,
-                 const std::vector<boost::intrusive_ptr<Connection> >& ,
+                 broker::Broker& donor, const ClusterMap& map, uint64_t frameId,
+                 const std::vector<boost::intrusive_ptr<Connection> >&, Decoder&,
                  const boost::function<void()>& done,
                  const boost::function<void(const std::exception&)>& fail,
                  const client::ConnectionSettings& 
@@ -92,9 +94,9 @@ class UpdateClient : public sys::Runnable {
     Url updateeUrl;
     broker::Broker& updaterBroker;
     ClusterMap map;
-    uint64_t eventId;
     uint64_t frameId;
     std::vector<boost::intrusive_ptr<Connection> > connections;
+    Decoder& decoder;
     client::Connection connection, shadowConnection;
     client::AsyncSession session, shadowSession;
     boost::function<void()> done;