rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Merge branch '159-general-fixes-and-tweaking' into 'master'

Browse source 
Resolve "General fixes and tweaking"

Closes #159

See merge request jankstudio/resq!160
This commit is contained in:
Kendrick Chan 2018-07-19 02:04:24 +00:00
commit ffafa47a95
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/Service/MQTTClient.php
View file

@ -37,7 +37,10 @@ class MQTTClient
$sessions = $job_order->getCustomer()->getMobileSessions(); $sessions = $job_order->getCustomer()->getMobileSessions();
if (count($sessions) == 0) if (count($sessions) == 0)
{
error_log("no sessions to send mqtt event to");
return; return;
{
// send to every customer session // send to every customer session
foreach ($sessions as $sess) foreach ($sessions as $sess)
@ -45,6 +48,8 @@ class MQTTClient
$phone_num = $sess->getPhoneNumber(); $phone_num = $sess->getPhoneNumber();
$channel = self::PREFIX . $phone_num; $channel = self::PREFIX . $phone_num;
$this->publish($channel, json_encode($payload)); $this->publish($channel, json_encode($payload));
error_log("sent to $channel");
} }
} }