Move registration API to configuration

[pti/o2.git] / o2app / entrypoints / redis_eventconsumer.py

diff --git a/o2app/entrypoints/redis_eventconsumer.py b/o2app/entrypoints/redis_eventconsumer.py
index d4c7c65..5630174 100644 (file)
--- a/o2app/entrypoints/redis_eventconsumer.py
+++ b/o2app/entrypoints/redis_eventconsumer.py
@@ -22,7 +22,8 @@ from o2dms.domain import commands
 from o2ims.domain import commands as imscmd
 
 from o2common.helper import o2logging
-from o2ims.domain.subscription_obj import Message2SMO, NotificationEventEnum, RegistrationMessage
+from o2ims.domain.subscription_obj import Message2SMO, NotificationEventEnum,\
+    RegistrationMessage
 logger = o2logging.get_logger(__name__)
 
 r = redis.Redis(**config.get_redis_host_and_port())
@@ -36,7 +37,7 @@ def main():
     pubsub = r.pubsub(ignore_subscribe_messages=True)
     pubsub.subscribe("NfDeploymentStateChanged")
     pubsub.subscribe('ResourceChanged')
-    pubsub.subscribe('RegistrationChanged')
+    pubsub.subscribe('ConfigurationChanged')
     pubsub.subscribe('OcloudChanged')
 
     for m in pubsub.listen():
@@ -71,10 +72,10 @@ def handle_dms_changed(m, bus):
             eventtype=data['notificationEventType'],
             updatetime=data['updatetime']))
         bus.handle(cmd)
-    elif channel == 'RegistrationChanged':
+    elif channel == 'ConfigurationChanged':
         datastr = m['data']
         data = json.loads(datastr)
-        logger.info('RegistrationChanged with cmd:{}'.format(data))
+        logger.info('ConfigurationChanged with cmd:{}'.format(data))
         cmd = imscmd.Register2SMO(data=RegistrationMessage(id=data['id']))
         bus.handle(cmd)
     elif channel == 'OcloudChanged':