Replaces direct use of aiokafka with osm_common message bus in agent and
lcmclient
Changes config handling to comply with the way it is handled in other modules,
by using a config file and overriding it with env vars.
Adds unit tests for message_bus_client.
Mon client remains using aiokafka directly, as there is no support yet for
auto_offset_reset configuration in osm_common.
Change-Id: I99615287cc934ce310105e86544a6bfe26bc0673
Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
diff --git a/setup.py b/setup.py
index 2a85f83..1d42c16 100644
--- a/setup.py
+++ b/setup.py
@@ -45,6 +45,7 @@
url=_url,
license=_license,
packages=[_name],
+ package_dir={_name: _name},
include_package_data=True,
install_requires=[
"aiokafka==0.4.*",
@@ -52,7 +53,8 @@
"jsonschema==2.6.*",
"six==1.11.*",
"pyyaml==3.*",
- "osm-common"
+ "pymysql",
+ "osm-common",
],
entry_points={
"console_scripts": [