From c93363a3dbaff713af0d6415794383b803de4f2c Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 10 Apr 2024 08:41:50 +0300 Subject: [PATCH] Fixed - incorrect sharded pubsub detection --- .../java/org/redisson/cluster/ClusterConnectionManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java index 0da06a0cd..2e8f11a43 100644 --- a/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java +++ b/redisson/src/main/java/org/redisson/cluster/ClusterConnectionManager.java @@ -177,7 +177,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager { MasterSlaveEntry entry = getEntrySet().iterator().next(); RedisConnection c = entry.connectionWriteOp(null).join(); try { - c.sync(RedisCommands.SPUBLISH, "", ""); + c.sync(RedisCommands.PUBSUB_SHARDNUMSUB); subscribeService.setShardingSupported(true); } catch (Exception e) { // skip