londiste: some handler fixes

diff --git a/python/londiste/bublin.py b/python/londiste/bublin.py
index 910f536c1525e6d743311ee2ab80a05a84b5e684..33527c025d8db0136d31d95cd287dfb31d6b38e9 100644 (file)
--- a/python/londiste/bublin.py
+++ b/python/londiste/bublin.py
@@ -8,7 +8,7 @@ from londiste.handler import BaseHandler
 __all__ = ['Bublin']
 
 class Bublin(BaseHandler):
-    plugin_name = 'bublin'
+    handler_name = 'bublin'
 
     bubbles_max_slot = None         # NUM_SLOTS - 1 (NUM_SLOTS -> power of 2)
     bubbles_local_slots = None      # dict with local slot numbers

diff --git a/python/londiste/playback.py b/python/londiste/playback.py
index 7cb2e119e7ff73cd97a1a422631984bd4ed25234..d8f06da0cdae344a3b5fd27fc543f5906eca98be 100644 (file)
--- a/python/londiste/playback.py
+++ b/python/londiste/playback.py
@@ -344,7 +344,7 @@ class Replicator(CascadedWorker):
         self.flush_sql(dst_curs)
 
         for p in self.used_plugins.values():
-            p.finish_batch(self.batch_info)
+            p.finish_batch(self._batch_info)
         self.used_plugins = {}
 
         # finalize table changes
@@ -527,7 +527,7 @@ class Replicator(CascadedWorker):
         except KeyError:
             p = t.get_plugin()
             self.used_plugins[ev.extra1] = p
-            p.prepare_batch(self.batch_info, dst_curs)
+            p.prepare_batch(self._batch_info, dst_curs)
      
         p.process_event(ev, self.apply_sql, dst_curs)