(rocketmq) branch develop updated: [ISSUE #7812] Remove reachable flag in brokers' available judgement.

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new d9526e7ab2 [ISSUE #7812] Remove reachable flag in brokers' available 
judgement.
d9526e7ab2 is described below

commit d9526e7ab2d7d1a01fc7456ee57dc655710e9c46
Author: Ji Juntao <juntao....@alibaba-inc.com>
AuthorDate: Mon Feb 5 08:55:26 2024 +0800

    [ISSUE #7812] Remove reachable flag in brokers' available judgement.
---
 .../org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
index d3ff7eb45a..f629fe44a8 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
@@ -238,7 +238,7 @@ public class LatencyFaultToleranceImpl implements 
LatencyFaultTolerance<String>
         }
 
         public boolean isAvailable() {
-            return reachableFlag && System.currentTimeMillis() >= 
startTimestamp;
+            return System.currentTimeMillis() >= startTimestamp;
         }
 
         public boolean isReachable() {