X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fplugins%2FvRealiseOps%2FvROPs_Webservice%2Fvrops_webservice;h=4a55e73e2b32ca853753b05789e854616683e66f;hb=13b6a3d5198e119aa17a2d32c16642364a80250b;hp=98533f12e26da58179b57f783503e1b14c6ec383;hpb=c7397b95dbaeebd7d872779eec809daed9e487cc;p=osm%2FMON.git

diff --git a/osm_mon/plugins/vRealiseOps/vROPs_Webservice/vrops_webservice b/osm_mon/plugins/vRealiseOps/vROPs_Webservice/vrops_webservice
index 98533f1..4a55e73 100755
--- a/osm_mon/plugins/vRealiseOps/vROPs_Webservice/vrops_webservice
+++ b/osm_mon/plugins/vRealiseOps/vROPs_Webservice/vrops_webservice
@@ -41,8 +41,8 @@ import os
 import json
 import sys
 import requests
-sys.path.append("../../../core/message_bus")
-from producer import KafkaProducer
+ys.path.append(os.path.join(os.path.dirname(os.path.abspath(__file__)), '..', '..', '..','..'))
+from osm_mon.core.message_bus.producer import KafkaProducer
 #from core.message_bus.producer import KafkaProducer
 
 try:
@@ -193,7 +193,7 @@ def notify_alarm(alarmID):
         logger.info("Alarm details: {}".format(alarm_data))
 
         #Publish Alarm details
-        kafkaMsgProducer = KafkaProducer()
+        kafkaMsgProducer = KafkaProducer("alarm_response")
         kafkaMsgProducer.publish(topic='alarm_response', key='notify_alarm', value=alarm_data)
 
         #return 201 on Success