diff --git a/src/Service/MQTTClient.php b/src/Service/MQTTClient.php
index 397d73fd..6f7341cf 100644
--- a/src/Service/MQTTClient.php
+++ b/src/Service/MQTTClient.php
@@ -82,7 +82,7 @@ class MQTTClient
         // send to every customer session
         foreach ($sessions as $sess)
         {
-            $phone_num = $sess->data->getPhoneNumber();
+            $phone_num = $sess['data']->getPhoneNumber();
 
             // use appropriate prefix so we have different channel names for new api
             $prefix = $sess->legacy ? self::PREFIX : self::PREFIX_APIv2;