Bugfix: Do not claim expired messages in SQlite.

Change-Id: I346e79cf7269fb2452a0bec22a61ad7fd2e9935b
2013-04-12 17:24:04 -04:00 · 2013-04-12 17:24:04 -04:00 · 84b1f4bee2
commit 84b1f4bee2
parent 0f612c1188
1 changed files with 1 additions and 0 deletions
--- a/marconi/storage/sqlite/controllers.py
+++ b/marconi/storage/sqlite/controllers.py
@ -314,6 +314,7 @@ class Claim(base.ClaimBase):
                  from Messages left join Locked
                    on id = msgid
                 where msgid is null
+                   and ttl > julianday() * 86400.0 - created
                   and qid = ?
                 limit ?''', qid, limit)