From 221e934c71bb9801f751b0f0b8c380c7ecc7413e Mon Sep 17 00:00:00 2001 From: Flaper Fesp Date: Thu, 2 May 2013 18:00:57 +0200 Subject: [PATCH] Set messages ttl to claims ttl 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 --- marconi/storage/mongodb/controllers.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/marconi/storage/mongodb/controllers.py b/marconi/storage/mongodb/controllers.py index f99526955..18df5c57d 100644 --- a/marconi/storage/mongodb/controllers.py +++ b/marconi/storage/mongodb/controllers.py @@ -484,7 +484,7 @@ class ClaimController(storage.ClaimBase): msg_ctrl._col.update({"q": queue, "e": {"$lt": expires}, "c.id": oid}, - {"$set": {"e": expires}}, + {"$set": {"e": expires, "t": ttl}}, upsert=False, multi=True) if updated != 0: @@ -529,7 +529,7 @@ class ClaimController(storage.ClaimBase): msg_ctrl._col.update({"q": qid, "e": {"$lt": expires}, "c.id": cid}, - {"$set": {"e": expires}}, + {"$set": {"e": expires, "t": ttl}}, upsert=False, multi=True) def delete(self, queue, claim_id, tenant=None):