| Sapan Bhatia | 26d40bc | 2014-05-12 15:28:02 -0400 | [diff] [blame] | 1 | import threading |
| 2 | import time |
| 3 | from ec2_observer.event_loop import PlanetStackObserver |
| 4 | from ec2_observer.event_manager import EventListener |
| 5 | from util.logger import Logger, logging |
| 6 | |
| 7 | logger = Logger(level=logging.INFO) |
| 8 | |
| 9 | class Backend: |
| 10 | |
| 11 | def run(self): |
| 12 | try: |
| 13 | # start the openstack observer |
| 14 | observer = PlanetStackObserver() |
| 15 | observer_thread = threading.Thread(target=observer.run) |
| 16 | observer_thread.start() |
| 17 | |
| 18 | # start event listene |
| 19 | event_manager = EventListener(wake_up=observer.wake_up) |
| 20 | event_manager_thread = threading.Thread(target=event_manager.run) |
| 21 | event_manager_thread.start() |
| 22 | except: |
| 23 | logger.log_exc("Exception in child thread") |
| 24 | |