Update src/main/java/redis/clients/jedis/mcf/CircuitBreakerCommandExecutor.java

ggivo · Copilot · web-flow · commit c17b6afa2109 · 2025-06-11T09:15:21.000+03:00
Co-authored-by: Copilot &lt;175728472+Copilot@users.noreply.github.com&gt;
diff --git a/src/main/java/redis/clients/jedis/mcf/CircuitBreakerCommandExecutor.java b/src/main/java/redis/clients/jedis/mcf/CircuitBreakerCommandExecutor.java
@@ -75,7 +75,8 @@ private boolean shouldRetryFailedInflightCommands() {
     }
 
     private boolean isActiveCluster(Cluster cluster) {
-        return provider.getCluster() != cluster;
+        Cluster activeCluster = provider.getCluster();
+        return activeCluster != null && !activeCluster.equals(cluster);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,8 @@ private boolean shouldRetryFailedInflightCommands() {`
`75`	`75`	`}`
`76`	`76`
`77`	`77`	`private boolean isActiveCluster(Cluster cluster) {`
`78`		`- return provider.getCluster() != cluster;`
	`78`	`+ Cluster activeCluster = provider.getCluster();`
	`79`	`+ return activeCluster != null && !activeCluster.equals(cluster);`
`79`	`80`	`}`
`80`	`81`
`81`	`82`	`/**`