X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=inline;f=planetstack%2Fopenstack%2Fevent_manager.py;h=ab50f66ec9577993a9bd9305b30bde367aef3c7e;hb=87e5e09d5973e0c027d109560acec9d84e26b2b6;hp=33c6bfbbad51356180f38b3fb0148c2266d09ec6;hpb=5c0c4557d76b3f1cec59dfe67a4e519137804170;p=plstackapi.git

diff --git a/planetstack/openstack/event_manager.py b/planetstack/openstack/event_manager.py
index 33c6bfb..ab50f66 100644
--- a/planetstack/openstack/event_manager.py
+++ b/planetstack/openstack/event_manager.py
@@ -2,7 +2,7 @@ import threading
 import requests, json
 
 from core.models import *
-from openstack.manager import OpenStackManager
+#from openstack.manager import OpenStackManager
 from planetstack.config import Config
 
 import os
@@ -17,7 +17,7 @@ def event(func):
 class EventHandler:
     # This code is currently not in use.
     def __init__(self):
-        self.manager = OpenStackManager()
+        pass #self.manager = OpenStackManager()
 
     @staticmethod
     def get_events():
@@ -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()