import json
from o2app import bootstrap
from o2common.config import config
+from o2common.adapter.notifications import SmoNotifications
from o2dms.domain import commands
from o2ims.domain import commands as imscmd
from o2ims.domain.subscription_obj import Message2SMO, RegistrationMessage
def main():
logger.info("Redis pubsub starting")
- bus = bootstrap.bootstrap()
+
+ notifications = SmoNotifications()
+ bus = bootstrap.bootstrap(notifications=notifications)
+
pubsub = r.pubsub(ignore_subscribe_messages=True)
pubsub.subscribe("NfDeploymentStateChanged")
pubsub.subscribe('OcloudChanged')
data = json.loads(datastr)
logger.info('OcloudChanged with cmd:{}'.format(data))
cmd = imscmd.Register2SMO(data=RegistrationMessage(
- data['notificationEventType'],
- id=data['id']))
+ id=data['id'], eventtype=data['notificationEventType'],
+ updatetime=data['updatetime']))
bus.handle(cmd)
elif channel == 'AlarmEventChanged':
datastr = m['data']