- 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'))