diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/QueueEvents.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/broker/QueueEvents.cpp | 25 |
1 files changed, 25 insertions, 0 deletions
diff --git a/qpid/cpp/src/qpid/broker/QueueEvents.cpp b/qpid/cpp/src/qpid/broker/QueueEvents.cpp index bba054b0b8..2c540ff1ad 100644 --- a/qpid/cpp/src/qpid/broker/QueueEvents.cpp +++ b/qpid/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<QueueObserver> observer(new EventGenerator(*this, enqueueOnly)); + queue.addObserver(observer); +} + QueueEvents::Event::Event(EventType t, const QueuedMessage& m) : type(t), msg(m) {} |