diff --git a/custom_components/mega/hub.py b/custom_components/mega/hub.py
index 5ee5c3d..0f62a7d 100644
--- a/custom_components/mega/hub.py
+++ b/custom_components/mega/hub.py
@@ -195,7 +195,8 @@ class MegaD:
 
     def _process_msg(self, msg):
         try:
-            _, port = msg.topic.split('/')
+            d = msg.topic.split('/')
+            port = d[-1]
         except ValueError:
             self.lg.warning('can not process %s', msg)
             return