X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Fcommon%2Fmon_client.py;fp=osm_policy_module%2Fcommon%2Fmon_client.py;h=76a6f52c5a052699b35e2da02cce4ba4e23c4d28;hb=a14cf16181c8b39f12c872c486e0b292c0068944;hp=5124ed5134ccd03772b085622fa8e470cd6e5a87;hpb=a96898dfaf088ac15560d15a7dcaf982c671ac2f;p=osm%2FPOL.git

diff --git a/osm_policy_module/common/mon_client.py b/osm_policy_module/common/mon_client.py
index 5124ed5..76a6f52 100644
--- a/osm_policy_module/common/mon_client.py
+++ b/osm_policy_module/common/mon_client.py
@@ -36,10 +36,9 @@ log = logging.getLogger(__name__)
 
 
 class MonClient:
-    def __init__(self, loop=None):
-        cfg = Config.instance()
-        self.kafka_server = '{}:{}'.format(cfg.OSMPOL_MESSAGE_HOST,
-                                           cfg.OSMPOL_MESSAGE_PORT)
+    def __init__(self, config: Config, loop=None):
+        self.kafka_server = '{}:{}'.format(config.get('message', 'host'),
+                                           config.get('message', 'port'))
         if not loop:
             loop = asyncio.get_event_loop()
         self.loop = loop