X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fplugins%2FvRealiseOps%2Fplugin_receiver.py;h=af56372287db03e45e4f42164b722c0f35ac01fd;hb=6c10123aa1538801c01d20f659197918967a9b7f;hp=18a5bcdaffed220303b8a79142dbc40163be7403;hpb=582a1a03bc2b0917c4c0ad8c276c17f2599174b2;p=osm%2FMON.git diff --git a/osm_mon/plugins/vRealiseOps/plugin_receiver.py b/osm_mon/plugins/vRealiseOps/plugin_receiver.py index 18a5bcd..af56372 100644 --- a/osm_mon/plugins/vRealiseOps/plugin_receiver.py +++ b/osm_mon/plugins/vRealiseOps/plugin_receiver.py @@ -27,16 +27,16 @@ responds using producer for vROPs """ 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"