Small fixes in the event layer for the observer

[plstackapi.git] / planetstack / openstack / event_manager.py

diff --git a/planetstack/openstack/event_manager.py b/planetstack/openstack/event_manager.py
index 33c6bfb..a849f09 100644 (file)
--- a/planetstack/openstack/event_manager.py
+++ b/planetstack/openstack/event_manager.py
@@ -102,13 +102,17 @@ class EventSender:
 class EventListener:
     def __init__(self,wake_up=None):
         self.handler = EventHandler()
-        self.wake_up = wake_up()
+        self.wake_up = wake_up
 
     def handle_event(self, payload):
         payload_dict = json.loads(payload)
-        event = payload_dict['event']
-        ctx = payload_dict['ctx']
-        self.handler.dispatch(event,**ctx)   
+
+       # The code below will come back when we optimize the observer syncs
+       # into 'small' and 'big' syncs.
+
+        #event = payload_dict['event']
+        #ctx = payload_dict['ctx']
+        #self.handler.dispatch(event,**ctx)   
 
         if (self.wake_up):
             self.wake_up()