Fix Bug 914: Updating VNFD the first time shows ProducerClosed error
Change-Id: I02f9ad72bbc4256954030b4d338af242d1f81b81
Signed-off-by: delacruzramo <pedro.delacruzramos@altran.com>
diff --git a/osm_common/msgkafka.py b/osm_common/msgkafka.py
index 1e22c9f..91775f2 100644
--- a/osm_common/msgkafka.py
+++ b/osm_common/msgkafka.py
@@ -64,11 +64,15 @@
:param msg: message content, can be string or dictionary
:return: None or raises MsgException on failing
"""
- try:
- self.loop.run_until_complete(self.aiowrite(topic=topic, key=key, msg=msg))
-
- except Exception as e:
- raise MsgException("Error writing {} topic: {}".format(topic, str(e)))
+ retry = 2 # Try two times
+ while retry:
+ try:
+ self.loop.run_until_complete(self.aiowrite(topic=topic, key=key, msg=msg))
+ break
+ except Exception as e:
+ retry -= 1
+ if retry == 0:
+ raise MsgException("Error writing {} topic: {}".format(topic, str(e)))
def read(self, topic):
"""