Fixed - incorrect sharded pubsub detection

10 months ago · c93363a3db
parent 5d93ee321c
commit c93363a3db
1 changed files with 1 additions and 1 deletions
--- 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