diff --git a/VERSION b/VERSION
index 9cf22a4..0cadbc1 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.5.4-dev
+2.5.5
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: