msg = self._create_scale_action_payload(nsr_id, name, action)
log.info("Sending scale action message: %s", json.dumps(msg))
self.producer.send(topic='lcm_pm', key='trigger_scaling', value=json.dumps(msg))
self.producer.flush()
msg = self._create_scale_action_payload(nsr_id, name, action)
log.info("Sending scale action message: %s", json.dumps(msg))
self.producer.send(topic='lcm_pm', key='trigger_scaling', value=json.dumps(msg))
self.producer.flush()