pgq.LocalConsumer: fix exception message

diff --git a/python/pgq/localconsumer.py b/python/pgq/localconsumer.py
index 780f9219432e4e91e73987cab9bca9cffc28c8da..55ea15b266dff9314bbf30a79bc0f2b9b0db75ae 100644 (file)
--- a/python/pgq/localconsumer.py
+++ b/python/pgq/localconsumer.py
@@ -120,7 +120,7 @@ class LocalConsumer(pgq.Consumer):
             self.process_local_event(db, batch_id, ev)
 
     def process_local_event(self, db, batch_id, ev):
-        raise Exception('process_remote_batch not implemented')
+        raise Exception('process_local_event not implemented')
 
     def is_batch_done(self):
         """Helper function to keep track of last successful batch