commit 12687733bcff063a4046e88da3c268549f30bc3c
author Scott Baker <smbaker@gmail.com> Tue Mar 19 15:40:57 2019 -0700
committer Scott Baker <smbaker@gmail.com> Fri Mar 22 17:56:58 2019 -0700
tree 0f653337f64dcaf7e954e168be8fae0d317628e1
parent 740ffc861f564957ef4c6ca88d4e617f92a712cf

SEBA-206 Report OLT link connectivity in OLTDevice model

Change-Id: Icb3a75d719adac6d8eea139fe9d00d34a11baecb

xos/synchronizer/volt-synchronizer.py

diff --git a/xos/synchronizer/volt-synchronizer.py b/xos/synchronizer/volt-synchronizer.py
index 5f82ca5..a5e3019 100755
--- a/xos/synchronizer/volt-synchronizer.py
+++ b/xos/synchronizer/volt-synchronizer.py
@@ -19,6 +19,7 @@
 import os
 from xossynchronizer import Synchronizer
 from xosconfig import Config
+from xoskafka import XOSKafkaProducer
 
 base_config_file = os.path.abspath(os.path.dirname(os.path.realpath(__file__)) + '/config.yaml')
 mounted_config_file = os.path.abspath(os.path.dirname(os.path.realpath(__file__)) + '/mounted_config.yaml')
@@ -28,4 +29,7 @@
 else:
     Config.init(base_config_file, 'synchronizer-config-schema.yaml')
 
+# init kafka producer connection
+XOSKafkaProducer.init()
+
 Synchronizer().run()