X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fentrypoints%2Fredis_eventconsumer.py;h=56301747563ae87b21ffa9b65cd436df911f5d34;hb=6c304dfab28ffd1bbe69b9ada3d11e8fbbde014b;hp=d4c7c659b2033b42e3e6d542a9083ae03b5ca23b;hpb=f69bcfa4e53700f89b2a82456602f472f92f40a8;p=pti%2Fo2.git

diff --git a/o2app/entrypoints/redis_eventconsumer.py b/o2app/entrypoints/redis_eventconsumer.py
index d4c7c65..5630174 100644
--- 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':