Fixed key typo
This commit is contained in:
parent
dc91eb4db3
commit
0e48bb4944
|
|
@ -265,7 +265,7 @@ class RedisChannelManager extends LocalChannelManager
|
|||
public function getGlobalConnectionsCount($appId, string $channelName = null): PromiseInterface
|
||||
{
|
||||
return $this->publishClient
|
||||
->hget($this->getRedisKey($appId, $channelName, ['stats']), 'connections')
|
||||
->hget($this->getRedisKey($appId, $channelName, ['stats']), 'current_connections_count')
|
||||
->then(function ($count) {
|
||||
return is_null($count) ? 0 : (int) $count;
|
||||
});
|
||||
|
|
@ -559,7 +559,7 @@ class RedisChannelManager extends LocalChannelManager
|
|||
public function incrementSubscriptionsCount($appId, string $channel = null, int $increment = 1): PromiseInterface
|
||||
{
|
||||
return $this->publishClient->hincrby(
|
||||
$this->getRedisKey($appId, $channel, ['stats']), 'connections', $increment
|
||||
$this->getRedisKey($appId, $channel, ['stats']), 'current_connections_count', $increment
|
||||
);
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue