new tests for cascading

1 files changed, 14 insertions, 0 deletions

diff --git a/tests/cascade/plainconsumer.py b/tests/cascade/plainconsumer.py
new file mode 100755
index 00000000..81bad948
--- /dev/null
+++ b/tests/cascade/plainconsumer.py
@@ -0,0 +1,14 @@
+#! /usr/bin/env python
+
+import sys, time, skytools
+
+from pgq.cascade.consumer import CascadedConsumer
+
+class PlainCascadedConsumer(CascadedConsumer):
+    def process_remote_event(self, src_curs, dst_curs, ev):
+        ev.tag_done()
+
+if __name__ == '__main__':
+    script = PlainCascadedConsumer('nop_consumer', 'dst_db', sys.argv[1:])
+    script.start()
+