pgq.Consumer: use lazy_fetch by default

New default_lazy_fetch class var to allow subclasses to turn it off.

diff --git a/python/pgq/consumer.py b/python/pgq/consumer.py
index 5a3a029cb7ee043847385d07d48dbdead5b189cb..58d4c48c28497900985b5ec0ed97020fa32f0c22 100644 (file)
--- 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