1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/Dispatcher.h b/cpp/src/qpid/client/Dispatcher.h
index 7d42bf8793..d85785ed2c 100644
--- a/cpp/src/qpid/client/Dispatcher.h
+++ b/cpp/src/qpid/client/Dispatcher.h
@@ -69,6 +69,8 @@ class Dispatcher : public sys::Runnable
     Subscriber::shared_ptr find(const std::string& name);
     bool isStopped();
 
+    boost::function<void ()> failoverHandler;
+
 public:
     Dispatcher(const Session& session, const std::string& queue = "");
 
@@ -77,6 +79,11 @@ public:
     void stop();
     void setAutoStop(bool b);
 
+    void registerFailoverHandler ( boost::function<void ()> fh )
+    {
+      failoverHandler = fh;
+    }
+
     void listen(MessageListener* listener, AckPolicy autoAck=AckPolicy());
     void listen(const std::string& destination, MessageListener* listener, AckPolicy autoAck=AckPolicy());
     void cancel(const std::string& destination);