1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/QueueListeners.h b/cpp/src/qpid/broker/QueueListeners.h
index 9bb847ff94..51ef58eb06 100644
--- a/cpp/src/qpid/broker/QueueListeners.h
+++ b/cpp/src/qpid/broker/QueueListeners.h
@@ -57,6 +57,11 @@ class QueueListeners
     void populate(NotificationSet&);
     bool contains(Consumer::shared_ptr c) const;
 
+    template <class F> void eachListener(F f) {
+        std::for_each(browsers.begin(), browsers.end(), f);
+        std::for_each(consumers.begin(), consumers.end(), f);
+    }
+
   private:
     Listeners consumers;
     Listeners browsers;