for issue WeBankFinTech#61:add log for cost time

keranbingaa · Sep 4, 2022 · 3176543 · 3176543
1 parent 7bf01c0
commit 3176543
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ient/src/main/java/com/webank/defibus/client/impl/consumer/DeFiBusPullMessageService.java b/...ient/src/main/java/com/webank/defibus/client/impl/consumer/DeFiBusPullMessageService.java
@@ -69,7 +69,7 @@ private void pullMessage(final PullRequest pullRequest) {
 
             long rt = System.currentTimeMillis() - beginPullRequestTime;
             if (rt >= brokerHealthyManager.getIsolateThreshold()) {
-                brokerHealthyManager.isolateBroker(pullRequest.getMessageQueue().getBrokerName());
+                brokerHealthyManager.isolateBroker(pullRequest.getMessageQueue().getBrokerName(), rt);
             }
         } else {
             log.warn("No matched consumer for the PullRequest {}, drop it", pullRequest);
@@ -154,10 +154,10 @@ public void removeIsolateBroker(String brokerName) {
             }
         }
 
-        public void isolateBroker(String brokerName) {
+        public void isolateBroker(String brokerName, long rt) {
             isolatedBroker.put(brokerName, System.currentTimeMillis());
             if (isolatedBroker.containsKey(brokerName)) {
-                log.info("isolate broker for slow pull message success, {}", brokerName);
+                log.info("isolate broker for slow pull message success, {}, cost:{} ms", brokerName, rt);
             }
         }