From 0e48bb49445572d9d9d2d20b1f8560ffbe0a12a6 Mon Sep 17 00:00:00 2001 From: Alex Renoki Date: Mon, 7 Dec 2020 19:44:26 +0200 Subject: [PATCH] Fixed key typo --- src/ChannelManagers/RedisChannelManager.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/ChannelManagers/RedisChannelManager.php b/src/ChannelManagers/RedisChannelManager.php index 01e3419..05cf66d 100644 --- a/src/ChannelManagers/RedisChannelManager.php +++ b/src/ChannelManagers/RedisChannelManager.php @@ -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 ); }