diff --git a/defibus-client/src/main/java/com/webank/defibus/client/impl/consumer/DeFiBusPullMessageService.java b/defibus-client/src/main/java/com/webank/defibus/client/impl/consumer/DeFiBusPullMessageService.java index da31e84..73f3371 100644 --- a/defibus-client/src/main/java/com/webank/defibus/client/impl/consumer/DeFiBusPullMessageService.java +++ b/defibus-client/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); } }