X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_mon%2Fcore%2Fmessage_bus%2Fcommon_consumer;h=efbb12218cc36062c7ba6058a03d667daefc74ba;hb=0e57d11ebb85637f38dd92a791abd6fe4889a565;hp=709c07e507fcbc83bfaf89790f34348ddf6e77b9;hpb=715a0ae6b46d22171c0f98c989cd971ea8b306bc;p=osm%2FMON.git

diff --git a/osm_mon/core/message_bus/common_consumer b/osm_mon/core/message_bus/common_consumer
index 709c07e..efbb122 100755
--- a/osm_mon/core/message_bus/common_consumer
+++ b/osm_mon/core/message_bus/common_consumer
@@ -47,7 +47,12 @@ from osm_mon.plugins.CloudWatch.access_credentials import AccessCredentials
 from osm_mon.plugins.vRealiseOps import plugin_receiver
 
 # Initialize servers
-server = {'server': 'localhost:9092'}
+if "BROKER_URI" in os.environ:
+    server = {'server': os.getenv("BROKER_URI")}
+else:
+    server = {'server': 'localhost:9092'}
+
+
 
 # Initialize consumers for alarms and metrics
 common_consumer = KafkaConsumer(bootstrap_servers=server['server'])