From 0f77d41a96adf95fd70904534825597c088136ee Mon Sep 17 00:00:00 2001
From: Zhihao Yuan <zhihao.yuan@rackspace.com>
Date: Tue, 16 Apr 2013 17:09:31 -0400
Subject: [PATCH] Bugfix: Exclude expired claimed messages in stats.

Change-Id: I6dcec40b967c29c8c291c8251b61949c7e672e26
---
 marconi/storage/mongodb/controllers.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/marconi/storage/mongodb/controllers.py b/marconi/storage/mongodb/controllers.py
index b333cebe0..8e494af3a 100644
--- a/marconi/storage/mongodb/controllers.py
+++ b/marconi/storage/mongodb/controllers.py
@@ -189,13 +189,12 @@ class MessageController(storage.MessageBase):
 
         query = {
             "c.id": claim_id,
+            "c.e": {"$gt": expires or timeutils.utcnow_ts()},
             "q": utils.to_oid(queue),
         }
         if not claim_id:
             # lookup over c.id to use the index
             query["c.id"] = {"$ne": None}
-        if expires:
-            query["c.e"] = {"$gt": expires}
 
         msgs = self._col.find(query, sort=[("_id", 1)])