X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Ftests%2Fintegration%2Ftest_kafka_messages.py;h=28b2e0f51ee9dc240a07a272ad07ab55d379a52f;hb=87c4af90c63a6b53f92fd84f20c2a29187db5765;hp=29d88e2db36989d3c5e9b7603714c6da6f75f888;hpb=16256cbbf6cdfde8debc3254bf55ce0b8fa51b08;p=osm%2FPOL.git

diff --git a/osm_policy_module/tests/integration/test_kafka_messages.py b/osm_policy_module/tests/integration/test_kafka_messages.py
index 29d88e2..28b2e0f 100644
--- a/osm_policy_module/tests/integration/test_kafka_messages.py
+++ b/osm_policy_module/tests/integration/test_kafka_messages.py
@@ -42,11 +42,10 @@ log.addHandler(stream_handler)
 class KafkaMessagesTest(unittest.TestCase):
     def setUp(self):
         super()
-        cfg = Config.instance()
-        self.kafka_server = '{}:{}'.format(cfg.OSMPOL_MESSAGE_HOST,
-                                           cfg.OSMPOL_MESSAGE_PORT)
+        cfg = Config()
+        self.kafka_server = '{}:{}'.format(cfg.get('message', 'host'),
+                                           cfg.get('message', 'port'))
         self.loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(None)
 
     def tearDown(self):
         super()