From 6a87cd223a386526ccca0a1ba6f0bdd1c4320ba1 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 15 Feb 2011 14:17:45 +0000 Subject: QPID-3002: Configurable threshold alerts for queues git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1070913 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/QueueEvents.cpp | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) (limited to 'cpp/src/qpid/broker/QueueEvents.cpp') diff --git a/cpp/src/qpid/broker/QueueEvents.cpp b/cpp/src/qpid/broker/QueueEvents.cpp index bba054b0b8..2c540ff1ad 100644 --- a/cpp/src/qpid/broker/QueueEvents.cpp +++ b/cpp/src/qpid/broker/QueueEvents.cpp @@ -19,6 +19,8 @@ * */ #include "qpid/broker/QueueEvents.h" +#include "qpid/broker/Queue.h" +#include "qpid/broker/QueueObserver.h" #include "qpid/Exception.h" #include "qpid/log/Statement.h" @@ -115,6 +117,29 @@ bool QueueEvents::isSync() return sync; } +class EventGenerator : public QueueObserver +{ + public: + EventGenerator(QueueEvents& mgr, bool enqOnly) : manager(mgr), enqueueOnly(enqOnly) {} + void enqueued(const QueuedMessage& m) + { + manager.enqueued(m); + } + void dequeued(const QueuedMessage& m) + { + if (!enqueueOnly) manager.dequeued(m); + } + private: + QueueEvents& manager; + const bool enqueueOnly; +}; + +void QueueEvents::observe(Queue& queue, bool enqueueOnly) +{ + boost::shared_ptr observer(new EventGenerator(*this, enqueueOnly)); + queue.addObserver(observer); +} + QueueEvents::Event::Event(EventType t, const QueuedMessage& m) : type(t), msg(m) {} -- cgit v1.2.1