From 3628789213806b41b3f6fc23059a2e717da96d7d Mon Sep 17 00:00:00 2001
From: Petr Jelinek
Date: Tue, 2 Jul 2013 11:53:59 +0200
Subject: Add consumer_filter option to simple_local_consumer.

---
 scripts/simple_local_consumer.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/scripts/simple_local_consumer.py b/scripts/simple_local_consumer.py
index 1c8f97dd..87c65868 100755
--- a/scripts/simple_local_consumer.py
+++ b/scripts/simple_local_consumer.py
@@ -13,6 +13,10 @@ Config::
 
     # query to call
     dst_query = select * from somefunc(%%(pgq.ev_data)s);
+
+    ## Use table_filter where possible instead of this ##
+    # filter for events (SQL fragment)
+    consumer_filter = ev_extra1 = 'public.mytable1'
 """
 
 
@@ -30,6 +34,8 @@ class SimpleLocalConsumer(pgq.LocalConsumer):
     def reload(self):
         super(SimpleLocalConsumer, self).reload()
         self.dst_query = self.cf.get("dst_query")
+        if self.cf.get("consumer_filter", ""):
+            self.consumer_filter = self.cf.get("consumer_filter", "")
 
     def process_local_event(self, db, batch_id, ev):
         curs = self.get_database('dst_db', autocommit = 1).cursor()
-- 
cgit v1.2.3