Change the magic value (2000) to a constant (NOT_FOUND_FLAG_VALID_TIME)

apache · Aug 2, 2021 · 6619d33 · 6619d33
1 parent 06864ae
commit 6619d33
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java
@@ -30,14 +30,15 @@ public class TopicPublishInfo {
     private volatile ThreadLocalIndex sendWhichQueue = new ThreadLocalIndex();
     private TopicRouteData topicRouteData;
     private long notFoundFlag = -1;
+    private static final int NOT_FOUND_FLAG_VALID_TIME = 2000;
 
     public void setNotFoundFlag() {
         if (!checkNotFoundFlag()) {
             notFoundFlag = System.currentTimeMillis();
         }
     }
 
-    public boolean checkNotFoundFlag() { return System.currentTimeMillis() < notFoundFlag + 2000; }
+    public boolean checkNotFoundFlag() { return System.currentTimeMillis() < notFoundFlag + NOT_FOUND_FLAG_VALID_TIME; }
 
     public boolean isOrderTopic() {
         return orderTopic;