projects
/
osm
/
RO.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Extracting Ns._ip_profile_to_ro() and creating unit test
[osm/RO.git]
/
NG-RO
/
osm_ng_ro
/
vim_admin.py
diff --git
a/NG-RO/osm_ng_ro/vim_admin.py
b/NG-RO/osm_ng_ro/vim_admin.py
index
17bfb20
..
d875272
100644
(file)
--- 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)
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(
kafka_working = True
self.logger.debug("Starting vim_account subscription task")
self.aiomain_task_kafka = asyncio.ensure_future(