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