commit e68244c75b2fc368b4ffcabde2502ce471a802a8
author amit.ghosh <amit.ghosh@radisys.com> Mon Nov 16 09:14:01 2020 +0100
committer amit.ghosh <amit.ghosh@radisys.com> Mon Nov 16 09:15:14 2020 +0100
tree 726fec7f439c1ffe9cf89094324147cf7e33ea10
parent 51f924b92428e60b1a5206a20935eafd6b6a3a37

VOL-3616:Handle each received kafka msg in a separate task

Change-Id: I12df9dd0f6dfbfa72ec91bb057e5361b4ea6dd6c

VERSION

diff --git a/VERSION b/VERSION
index 9cf22a4..0cadbc1 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.5.4-dev
+2.5.5

pyvoltha/adapters/kafka/kafka_inter_container_library.py

diff --git a/pyvoltha/adapters/kafka/kafka_inter_container_library.py b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
index 1b005e7..07508b9 100644
--- a/pyvoltha/adapters/kafka/kafka_inter_container_library.py
+++ b/pyvoltha/adapters/kafka/kafka_inter_container_library.py
@@ -294,7 +294,7 @@
         while True:
             try:
                 message = yield self.received_msg_queue.get()
-                yield self._process_message(message)
+                reactor.callLater(0, self._process_message, message)
                 if self.stopped:
                     break
             except Exception as e: