X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Fcommon%2Flcm_client.py;fp=osm_policy_module%2Fcommon%2Flcm_client.py;h=05378d7c4797f1b8234e335fdfa7e3d5dc05c149;hb=312c16596975a42d6294a1a2ca7af98b0ff2ffb5;hp=3d8012f00c2ee6900a2a4ff7fc94cd33aa15117c;hpb=93f1b1305cef4f52581c80dbbe2ed6ccef1bbeab;p=osm%2FPOL.git diff --git a/osm_policy_module/common/lcm_client.py b/osm_policy_module/common/lcm_client.py index 3d8012f..05378d7 100644 --- a/osm_policy_module/common/lcm_client.py +++ b/osm_policy_module/common/lcm_client.py @@ -42,8 +42,7 @@ class LcmClient: self.kafka_server = '{}:{}'.format(cfg.OSMPOL_MESSAGE_HOST, cfg.OSMPOL_MESSAGE_PORT) self.common_db = dbmongo.DbMongo() - self.common_db.db_connect({'host': cfg.OSMPOL_DATABASE_HOST, - 'port': int(cfg.OSMPOL_DATABASE_PORT), + self.common_db.db_connect({'uri': cfg.OSMPOL_DATABASE_URI, 'name': 'osm'}) if not loop: loop = asyncio.get_event_loop()