openstack/zaqar
Code Issues Proposed changes

Set messages ttl to claims ttl

Browse Source 
Make sure messages being updated have the same ttl as claim. This update
happens when claimed messages have a ttl lower than claim's.

Implements blueprint storage-mongodb

Change-Id: Ide529895760fd6e1b207611729e1da5e250cbafb
This commit is contained in:
Flaper Fesp
2013-05-02 18:00:57 +02:00
parent f3963d0a8c
commit 221e934c71
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
marconi/storage/mongodb/controllers.py
View File

@@ -484,7 +484,7 @@ class ClaimController(storage.ClaimBase):
msg_ctrl._col.update({"q": queue, msg_ctrl._col.update({"q": queue,
"e": {"$lt": expires}, "e": {"$lt": expires},
"c.id": oid}, "c.id": oid},
{"$set": {"e": expires}}, {"$set": {"e": expires, "t": ttl}},
upsert=False, multi=True) upsert=False, multi=True)
if updated != 0: if updated != 0:
@@ -529,7 +529,7 @@ class ClaimController(storage.ClaimBase):
msg_ctrl._col.update({"q": qid, msg_ctrl._col.update({"q": qid,
"e": {"$lt": expires}, "e": {"$lt": expires},
"c.id": cid}, "c.id": cid},
{"$set": {"e": expires}}, {"$set": {"e": expires, "t": ttl}},
upsert=False, multi=True) upsert=False, multi=True)
def delete(self, queue, claim_id, tenant=None): def delete(self, queue, claim_id, tenant=None):