Skip to content
This repository was archived by the owner on Feb 7, 2024. It is now read-only.

Commit ebfab2e

Browse files
committed
Fixed wrong keys names.
1 parent 9938cf6 commit ebfab2e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/PubSub/Drivers/RedisClient.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ public function unsubscribe($appId, string $channel): bool
161161

162162
// If we no longer have subscriptions to that channel, unsubscribe
163163
if ($this->subscribedChannels["{$appId}:{$channel}"] < 1) {
164-
$this->subscribeClient->__call('unsubscribe', ["{$appId}:{$channel}"]);
164+
$this->subscribeClient->__call('unsubscribe', [$this->getTopicName($appId, $channel)]);
165165

166166
unset($this->subscribedChannels["{$appId}:{$channel}"]);
167167
}
@@ -187,7 +187,7 @@ public function unsubscribe($appId, string $channel): bool
187187
*/
188188
public function joinChannel($appId, string $channel, string $socketId, string $data)
189189
{
190-
$this->publishClient->__call('hset', ["{$appId}:{$channel}", $socketId, $data]);
190+
$this->publishClient->__call('hset', [$this->getTopicName($appId, $channel), $socketId, $data]);
191191

192192
DashboardLogger::log($appId, DashboardLogger::TYPE_REPLICATOR_JOINED_CHANNEL, [
193193
'channel' => $channel,

0 commit comments

Comments
 (0)