diff --git a/voltha/adapters/openolt/openolt_indications.py b/voltha/adapters/openolt/openolt_indications.py
index 54415ba..4873984 100644
--- a/voltha/adapters/openolt/openolt_indications.py
+++ b/voltha/adapters/openolt/openolt_indications.py
@@ -42,7 +42,10 @@
 
     def indications_thread(self):
         self.log.debug('openolt indications thread starting')
-        KConsumer(self.indications_process, "openolt.ind")
+
+        KConsumer(self.indications_process,
+                  'openolt.ind-{}'.format(
+                      self.device.host_and_port.split(':')[0]))
 
     def indications_process(self, topic, msg):