X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcmd%2Fmon_dashboarder.py;h=b49b570cbd03a7bbf10d2602dcb9854adff9564f;hb=85a9185db3248f1e3f20c8edad95ab77b8ee989c;hp=211038d4c734a02ccf09acbdb7f8edc72ed87f27;hpb=456d0f323cfcb5fe6b8cad5a6c3e6633875633cd;p=osm%2FMON.git

diff --git a/osm_mon/cmd/mon_dashboarder.py b/osm_mon/cmd/mon_dashboarder.py
index 211038d..b49b570 100644
--- a/osm_mon/cmd/mon_dashboarder.py
+++ b/osm_mon/cmd/mon_dashboarder.py
@@ -27,6 +27,7 @@ import sys
 
 from osm_mon.core.config import Config
 from osm_mon.dashboarder.dashboarder import Dashboarder
+import threading
 
 
 def main():
@@ -47,6 +48,9 @@ def main():
     log.info("Starting MON Dashboarder...")
     log.debug("Config: %s", cfg.conf)
     dashboarder = Dashboarder(cfg)
+    log.info("Starting MON kafka Consumer...")
+    threading.Thread(target=dashboarder.run, args=()).start()
+    log.info("Starting MON Dashboarder...")
     dashboarder.dashboard_forever()