From 1b93e81b0990b8d819670999172c444d1476908a Mon Sep 17 00:00:00 2001 From: Marko Kreen Date: Fri, 11 Sep 2009 14:21:32 +0300 Subject: [PATCH] pgq.Consumer: use lazy_fetch by default New default_lazy_fetch class var to allow subclasses to turn it off. --- python/pgq/consumer.py | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py index 5a3a029c..58d4c48c 100644 --- a/python/pgq/consumer.py +++ b/python/pgq/consumer.py @@ -103,6 +103,16 @@ class Consumer(skytools.DBScript): """Consumer base class. """ + default_lazy_fetch = 300 + + # proper variables + consumer_name = None + queue_name = None + + # compat variables + pgq_queue_name = None + pgq_consumer_id = None + def __init__(self, service_name, db_name, args): """Initialize new consumer. @@ -125,7 +135,7 @@ class Consumer(skytools.DBScript): if not self.queue_name: self.queue_name = self.cf.get("queue_name") - self.pgq_lazy_fetch = self.cf.getint("pgq_lazy_fetch", 0) + self.pgq_lazy_fetch = self.cf.getint("pgq_lazy_fetch", self.default_lazy_fetch) self.stat_batch_start = 0 # compat vars -- 2.39.5