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

Merge branch '162-phase-2-changes' into 'master'

Browse source 
Resolve "Phase 2 changes"

Closes #162

See merge request jankstudio/resq!175
This commit is contained in:
Kendrick Chan 2018-08-15 01:15:17 +00:00
commit a8f72e8ee4
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/Service/MQTTClient.php
View file

@ -57,14 +57,23 @@ class MQTTClient
return;
}
$channels = [];
// send to every customer session
foreach ($sessions as $sess)
{
$phone_num = $sess->getPhoneNumber();
$channel = self::PREFIX . $phone_num;
$this->publish($channel, json_encode($payload));
error_log('sent to ' . $channel);
// gather channels, so we only send once
$channels[$channel] = json_encode($payload);
}
foreach ($channels as $channel => $json_payload)
{
$this->publish($channel, $json_payload);
// error_log('sent to ' . $channel);
}
}