import requests, json
from core.models import *
-from openstack.manager import OpenStackManager
+#from openstack.manager import OpenStackManager
from planetstack.config import Config
import os
class EventHandler:
# This code is currently not in use.
def __init__(self):
- self.manager = OpenStackManager()
+ pass #self.manager = OpenStackManager()
@staticmethod
def get_events():
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()