Periodically purge expired messages from queues

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@704166 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 13 insertions, 0 deletions

diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp
index 315da23965..ccd7c1fa3e 100644
--- a/cpp/src/qpid/broker/Queue.cpp
+++ b/cpp/src/qpid/broker/Queue.cpp
@@ -403,6 +403,19 @@ QueuedMessage Queue::get(){
     return msg;
 }
 
+void Queue::purgeExpired()
+{
+    Mutex::ScopedLock locker(messageLock);
+    for (Messages::iterator i = messages.begin(); i != messages.end(); ) {
+        if (i->payload->hasExpired()) {
+            dequeue(0, *i);
+            i = messages.erase(i);
+        } else {
+            ++i;
+        }
+    } 
+}
+
 /**
  * purge - for purging all or some messages on a queue
  *         depending on the purge_request