We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aaac8f7 commit 2ffffefCopy full SHA for 2ffffef
src/main/java/redis/clients/jedis/providers/MultiClusterPooledConnectionProvider.java
@@ -336,7 +336,8 @@ private void processPendingHealthStatusChanges() {
336
// Process all queued events
337
while ((event = pendingHealthStatusChanges.poll()) != null) {
338
Endpoint endpoint = event.getEndpoint();
339
- boolean latestInTheQueue = !pendingHealthStatusChanges.stream().anyMatch(e -> e.getEndpoint().equals(endpoint));
+ boolean latestInTheQueue = !pendingHealthStatusChanges.stream()
340
+ .anyMatch(e -> e.getEndpoint().equals(endpoint));
341
if (latestInTheQueue) {
342
processStatusChangeEvent(event);
343
}
0 commit comments