diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php index 476f51f..e0450bd 100644 --- a/src/Channels/Channel.php +++ b/src/Channels/Channel.php @@ -136,6 +136,18 @@ class Channel return true; } + /** + * Broadcast a payload to the locally-subscribed connections. + * + * @param string|int $appId + * @param \stdClass $payload + * @return bool + */ + public function broadcastLocally($appId, stdClass $payload): bool + { + return $this->broadcast($appId, $payload, false); + } + /** * Broadcast the payload, but exclude a specific socket id. * diff --git a/src/DashboardLogger.php b/src/DashboardLogger.php index 3309571..3ab4ded 100644 --- a/src/DashboardLogger.php +++ b/src/DashboardLogger.php @@ -83,15 +83,13 @@ class DashboardLogger $channel = $channelManager->find($appId, $channelName); if ($channel) { - $channel->broadcastToEveryoneExcept( - (object) $payload, - null, - $appId - ); - } else { - $channelManager->broadcastAcrossServers( - $appId, null, $channelName, (object) $payload + $channel->broadcastLocally( + $appId, (object) $payload, true ); } + + $channelManager->broadcastAcrossServers( + $appId, null, $channelName, (object) $payload + ); } }