ignore unknown command

redis · Apr 6, 2023 · 79b23f9 · 79b23f9
1 parent a3417fc
commit 79b23f9
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/main/java/redis/clients/jedis/Connection.java b/src/main/java/redis/clients/jedis/Connection.java
@@ -383,11 +383,17 @@ private void initializeFromClientConfig(JedisClientConfig config) {
           sendCommand(arg);
         }
 
-        // getMany and ignore result
-        getMany(fireAndForgetMsg.size());
+        flush();
 
+        for (int i = 0; i < fireAndForgetMsg.size(); i++) {
+          readProtocolWithCheckingBroken();
+        }
       } catch (JedisDataException e) {
-        // just ignore dataException, such as unknown command
+        if (e.getMessage().contains("unknown")) {
+          // just ignore dataException, such as unknown command
+        } else {
+          throw e;
+        }
       }
     } catch (JedisException je) {
       try {