From: garciadeblas <gerardo.garciadeblas@telefonica.com>
Date: Thu, 20 May 2021 11:08:05 +0000 (+0200)
Subject: Fix bug 1537 to send dummy message to all kafka topics during startup
X-Git-Tag: v9.1.2~4
X-Git-Url: https://osm.etsi.org/gitweb/?a=commitdiff_plain;h=refs%2Fchanges%2F48%2F10948%2F1;p=osm%2FRO.git

Fix bug 1537 to send dummy message to all kafka topics during startup

Change-Id: I1ceeae4236f45fad1c971276412c71b6eb67c9de
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>
(cherry picked from commit dc5ab15614e902e96466357c93731d7ee11945bf)
---

diff --git a/NG-RO/osm_ng_ro/vim_admin.py b/NG-RO/osm_ng_ro/vim_admin.py
index 17bfb202..d8752724 100644
--- a/NG-RO/osm_ng_ro/vim_admin.py
+++ b/NG-RO/osm_ng_ro/vim_admin.py
@@ -277,9 +277,10 @@ class VimAdminThread(threading.Thread):
             try:
                 if not self.aiomain_task_kafka:
                     # await self.msg.aiowrite("admin", "echo", "dummy message", loop=self.loop)
-                    await self.msg.aiowrite(
-                        "vim_account", "echo", "dummy message", loop=self.loop
-                    )
+                    for kafka_topic in self.kafka_topics:
+                        await self.msg.aiowrite(
+                            kafka_topic, "echo", "dummy message", loop=self.loop
+                        )
                     kafka_working = True
                     self.logger.debug("Starting vim_account subscription task")
                     self.aiomain_task_kafka = asyncio.ensure_future(