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=af56372287db03e45e4f42164b722c0f35ac01fd;hpb=75512477988ae5e287433c6c859c61de1bc82318;p=osm%2FMON.git diff --git a/osm_mon/plugins/vRealiseOps/plugin_receiver.py b/osm_mon/plugins/vRealiseOps/plugin_receiver.py index af56372..9526e64 100644 --- a/osm_mon/plugins/vRealiseOps/plugin_receiver.py +++ b/osm_mon/plugins/vRealiseOps/plugin_receiver.py @@ -26,14 +26,16 @@ Montoring plugin receiver that consumes the request messages & responds using producer for vROPs """ -import sys -import os import json import logging +import os +import sys import traceback -from mon_plugin_vrops import MonPlugin -from kafka_consumer_vrops import vROP_KafkaConsumer + + #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