Initialize checkStamp in LatencyFaultToleranceImpl.FaultItem

client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java

@@ -202,6 +202,7 @@ public class FaultItem implements Comparable<FaultItem> {
 
         public FaultItem(final String name) {
             this.name = name;
+            this.checkStamp = System.currentTimeMillis() + LatencyFaultToleranceImpl.this.detectInterval;
         }
 
         public void updateNotAvailableDuration(long notAvailableDuration) {

client/src/test/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImplTest.java

@@ -19,11 +19,17 @@
 import org.awaitility.core.ThrowingRunnable;
 import org.junit.Before;
 import org.junit.Test;
+import org.mockito.Mockito;
 
 import java.util.concurrent.TimeUnit;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
+import static org.mockito.ArgumentMatchers.anyLong;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
 
 public class LatencyFaultToleranceImplTest {
     private LatencyFaultTolerance<String> latencyFaultTolerance;
@@ -80,4 +86,19 @@ public void testIsReachable() throws Exception {
         latencyFaultTolerance.updateFaultItem(anotherBrokerName, 1001, 3000, false);
         assertThat(latencyFaultTolerance.isReachable(anotherBrokerName)).isEqualTo(false);
     }
-}
+
+    @Test
+    public void testDetectByOneRoundRespectsDetectInterval() throws Exception {
+        Resolver resolver = mock(Resolver.class);
+        ServiceDetector serviceDetector = mock(ServiceDetector.class);
+        when(resolver.resolve(brokerName)).thenReturn("127.0.0.1:10911");
+        when(serviceDetector.detect(anyString(), anyLong())).thenReturn(true);
+
+        LatencyFaultToleranceImpl impl = new LatencyFaultToleranceImpl(resolver, serviceDetector);
+        impl.setDetectInterval(3600000); // 1 hour
+        impl.updateFaultItem(brokerName, 1000, 0, true);
+        // fresh FaultItem must wait detectInterval before its first detect
+        impl.detectByOneRound();
+        verify(serviceDetector, Mockito.never()).detect(anyString(), anyLong());
+    }
+}