2 files changed, 11 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/DumpClient.cpp b/cpp/src/qpid/cluster/DumpClient.cpp
index c78859cc39..45ccec7166 100644
--- a/cpp/src/qpid/cluster/DumpClient.cpp
+++ b/cpp/src/qpid/cluster/DumpClient.cpp
@@ -186,8 +186,16 @@ void DumpClient::dumpSession(broker::SessionHandler& sh) {
     client::Session cs;
     client::SessionBase_0_10Access(cs).set(simpl);
     cs.sync();
+
+    broker::SessionState* ss = sh.getSession();
+    ss->eachConsumer(boost::bind(&DumpClient::dumpConsumer, this, _1));
+    
     // FIXME aconway 2008-09-19: remaining session state.
     QPID_LOG(debug, "Dump done, session " << sh.getSession()->getId());
 }
 
+void DumpClient::dumpConsumer(broker::SemanticState::ConsumerImpl* ci) {
+    QPID_LOG(critical, "DEBUG: dump consumer: " << ci->getName());
+}
+
 }} // namespace qpid::cluster
diff --git a/cpp/src/qpid/cluster/DumpClient.h b/cpp/src/qpid/cluster/DumpClient.h
index 6cd382667a..6ce41a53a9 100644
--- a/cpp/src/qpid/cluster/DumpClient.h
+++ b/cpp/src/qpid/cluster/DumpClient.h
@@ -24,6 +24,7 @@
 
 #include "qpid/client/Connection.h"
 #include "qpid/client/AsyncSession.h"
+#include "qpid/broker/SemanticState.h"
 #include "qpid/sys/Runnable.h"
 #include <boost/shared_ptr.hpp>
 
@@ -69,7 +70,8 @@ class DumpClient : public sys::Runnable {
     void dumpBinding(const std::string& queue, const broker::QueueBinding& binding);
     void dumpConnection(const boost::intrusive_ptr<Connection>& connection);
     void dumpSession(broker::SessionHandler& s);
-
+    void dumpConsumer(broker::SemanticState::ConsumerImpl*);
+    
   private:
     Url receiver;
     Cluster& donor;