X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=core%2Fmessage_bus%2Fconsumer.py;h=c9021d217c2975784918ccd154e6385679a2c7e7;hb=refs%2Fchanges%2F01%2F5701%2F1;hp=3995084224720bd04a1b857617fa25f181196ae4;hpb=375f07c018e209ae54391d4d0cb4898d4bdb79b4;p=osm%2FMON.git

diff --git a/core/message_bus/consumer.py b/core/message_bus/consumer.py
index 3995084..c9021d2 100644
--- a/core/message_bus/consumer.py
+++ b/core/message_bus/consumer.py
@@ -27,7 +27,7 @@ alarms and metrics responses.
 '''
 
 __author__ = "Prithiv Mohan"
-__date__   = "06/Sep/2017"
+__date__ = "06/Sep/2017"
 
 
 from kafka import KafkaConsumer
@@ -37,6 +37,7 @@ import logging
 import logging.config
 import os
 
+
 def logging_handler(filename, mode='a+', encoding=None):
     if not os.path.exists(filename):
         open(filename, 'a').close()
@@ -50,9 +51,9 @@ log_config = {
         },
     },
     'handlers': {
-        'file':{
+        'file': {
             '()': logging_handler,
-            'level':'DEBUG',
+            'level': 'DEBUG',
             'formatter': 'default',
             'filename': '/var/log/osm_mon.log',
             'mode': 'a+',
@@ -78,8 +79,10 @@ if "BROKER_URI" in os.environ:
 else:
     broker = "localhost:9092"
 
-alarm_consumer = KafkaConsumer('alarm_response', 'osm_mon', bootstrap_servers = broker)
-metric_consumer = KafkaConsumer('metric_response', 'osm_mon', bootstrap_servers = broker)
+alarm_consumer = KafkaConsumer(
+    'alarm_response', 'osm_mon', bootstrap_servers=broker)
+metric_consumer = KafkaConsumer(
+    'metric_response', 'osm_mon', bootstrap_servers=broker)
 try:
     for message in alarm_consumer:
         logger.debug(message)