Change-Id: I592fb01c819a8cbf1c1670bd08dec56370b58489
Signed-off-by: bhangare <sbhangare@vmware.com>
"""
import sys
+import os
+import json
+import logging
+import traceback
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
+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
-import json
-import logging
-import traceback
-import os
from xml.etree import ElementTree as XmlElementTree
schema_version = "1.0"
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: