+ channel = m['channel'].decode("UTF-8")
+ if channel == "NfDeploymentStateChanged":
+ datastr = m['data']
+ data = json.loads(datastr)
+ logger.info('HandleNfDeploymentStateChanged with cmd:{}'.format(data))
+ cmd = commands.HandleNfDeploymentStateChanged(
+ NfDeploymentId = data['NfDeploymentId'],
+ FromState = data['FromState'],
+ ToState = data['ToState']
+ )
+ bus.handle(cmd)
+ else:
+ logger.info("unhandled:{}".format(channel))