Skip to content
Snippets Groups Projects
Commit e9f6a757 authored by garciadeblas's avatar garciadeblas Committed by sousaedu
Browse files

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


Change-Id: I1ceeae4236f45fad1c971276412c71b6eb67c9de
Signed-off-by: default avatargarciadeblas <gerardo.garciadeblas@telefonica.com>
parent d777b0d2
No related branches found
No related tags found
No related merge requests found
...@@ -277,9 +277,10 @@ class VimAdminThread(threading.Thread): ...@@ -277,9 +277,10 @@ class VimAdminThread(threading.Thread):
try: try:
if not self.aiomain_task_kafka: if not self.aiomain_task_kafka:
# await self.msg.aiowrite("admin", "echo", "dummy message", loop=self.loop) # await self.msg.aiowrite("admin", "echo", "dummy message", loop=self.loop)
await self.msg.aiowrite( for kafka_topic in self.kafka_topics:
"vim_account", "echo", "dummy message", loop=self.loop await self.msg.aiowrite(
) kafka_topic, "echo", "dummy message", loop=self.loop
)
kafka_working = True kafka_working = True
self.logger.debug("Starting vim_account subscription task") self.logger.debug("Starting vim_account subscription task")
self.aiomain_task_kafka = asyncio.ensure_future( self.aiomain_task_kafka = asyncio.ensure_future(
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment