v0.8.0 redis 7 support

leonchen83 · Feb 1, 2022 · 25b1577 · 25b1577
1 parent 0856431
commit 25b1577
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rst/ClusterRdbVisitor.java b/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rst/ClusterRdbVisitor.java
@@ -470,7 +470,8 @@ public void retry(CombineCommand command, int times) {
             GenericKeyCommand cmd = (GenericKeyCommand) parsedCommand;
             retry(command, slot(cmd.getKey()), times);
         } else if (parsedCommand instanceof PublishCommand) {
-            broadcast(command, times); // broadcast function command
+            PublishCommand cmd = (PublishCommand) parsedCommand;
+            retry(command, slot(cmd.getChannel()), times);
         } else {
             // swapdb
             // move