diff --git a/src/ChannelManagers/RedisChannelManager.php b/src/ChannelManagers/RedisChannelManager.php index 9c24c92..3d79156 100644 --- a/src/ChannelManagers/RedisChannelManager.php +++ b/src/ChannelManagers/RedisChannelManager.php @@ -462,7 +462,7 @@ class RedisChannelManager extends LocalChannelManager unset($payload->serverId); unset($payload->appId); - $channel->broadcastToEveryoneExcept($payload, $socketId, $appId, false); + $channel->broadcastLocallyToEveryoneExcept($payload, $socketId, $appId); } /** diff --git a/src/Channels/Channel.php b/src/Channels/Channel.php index 126b6c7..476f51f 100644 --- a/src/Channels/Channel.php +++ b/src/Channels/Channel.php @@ -164,6 +164,21 @@ class Channel return true; } + /** + * Broadcast the payload, but exclude a specific socket id. + * + * @param \stdClass $payload + * @param string|null $socketId + * @param string|int $appId + * @return bool + */ + public function broadcastLocallyToEveryoneExcept(stdClass $payload, ?string $socketId, $appId) + { + return $this->broadcastToEveryoneExcept( + $payload, $socketId, $appId, false + ); + } + /** * Check if the signature for the payload is valid. *