X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fplugins%2FvRealiseOps%2Fplugin_receiver.py;h=9526e64475877365ae8cdf1dcb116ea1ab3a3104;hb=refs%2Fchanges%2F60%2F6060%2F4;hp=18a5bcdaffed220303b8a79142dbc40163be7403;hpb=e5f3efeec953b44f79386416c1f0a8d0b964cc46;p=osm%2FMON.git

diff --git a/osm_mon/plugins/vRealiseOps/plugin_receiver.py b/osm_mon/plugins/vRealiseOps/plugin_receiver.py
index 18a5bcd..9526e64 100644
--- a/osm_mon/plugins/vRealiseOps/plugin_receiver.py
+++ b/osm_mon/plugins/vRealiseOps/plugin_receiver.py
@@ -26,17 +26,19 @@ Montoring plugin receiver that consumes the request messages &
 responds using producer for vROPs
 """
 
-import sys
-from mon_plugin_vrops import MonPlugin
-from kafka_consumer_vrops import vROP_KafkaConsumer
-#Core producer
-sys.path.append("../../core/message_bus")
-from producer import KafkaProducer
-#from core.message_bus.producer import KafkaProducer
 import json
 import logging
-import traceback
 import os
+import sys
+import traceback
+
+
+#Core producer
+from osm_mon.plugins.vRealiseOps.mon_plugin_vrops import MonPlugin
+
+sys.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
 from xml.etree import ElementTree as XmlElementTree
 
 schema_version = "1.0"