ClusterNodesDecoder ignore unknown flag and avoid throwing exception

5 years ago · 91df94fcce
parent 7bb7e1066b
commit 91df94fcce
1 changed files with 6 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/client/protocol/decoder/ClusterNodesDecoder.java
+++ b/redisson/src/main/java/org/redisson/client/protocol/decoder/ClusterNodesDecoder.java
@ -56,7 +56,12 @@ public class ClusterNodesDecoder implements Decoder<List<ClusterNodeInfo>> {
            String flags = params[2];
            for (String flag : flags.split(",")) {
                String flagValue = flag.toUpperCase().replaceAll("\\?", "");
-                node.addFlag(ClusterNodeInfo.Flag.valueOf(flagValue));
+                for (Flag nodeInfoFlag : ClusterNodeInfo.Flag.values()) {
+                    if (nodeInfoFlag.name().equals(flagValue)) {
+                        node.addFlag(nodeInfoFlag);
+                        break;
+                    }
+                }
            }
            
            if (!node.containsFlag(Flag.NOADDR)) {