Congegni/sintonia
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

cc-1799 : filesystem

Browse source
This commit is contained in:
Naomi Aro 2011-06-27 18:30:52 +02:00
parent e8265614ba
commit f3746ff197
1 changed files with 4 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
python_apps/media-monitor/airtimefilemonitor/airtimenotifier.py
View file

@ -30,10 +30,9 @@ class AirtimeNotifier(Notifier):
while not self.init_rabbit_mq(): while not self.init_rabbit_mq():
logger.error("Error connecting to RabbitMQ Server. Trying again in few seconds") logger.error("Error connecting to RabbitMQ Server. Trying again in few seconds")
time.sleep(5) time.sleep(5)
def init_rabbit_mq(self): def init_rabbit_mq(self):
logger = logging.getLogger('fetch') self.logger.info("Initializing RabbitMQ stuff")
logger.info("Initializing RabbitMQ stuff")
try: try:
schedule_exchange = Exchange("airtime-media-monitor", "direct", durable=True, auto_delete=True) schedule_exchange = Exchange("airtime-media-monitor", "direct", durable=True, auto_delete=True)
schedule_queue = Queue("media-monitor", exchange=schedule_exchange, key="filesystem") schedule_queue = Queue("media-monitor", exchange=schedule_exchange, key="filesystem")
@ -43,9 +42,9 @@ class AirtimeNotifier(Notifier):
consumer.register_callback(self.handle_message) consumer.register_callback(self.handle_message)
consumer.consume() consumer.consume()
except Exception, e: except Exception, e:
logger.error(e) self.logger.error(e)
return False return False
return True return True
def handle_message(self, body, message): def handle_message(self, body, message):