You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2020/09/12 11:39:21 UTC
[rocketmq] branch develop updated: [ISSUE #2293] Add clientID for
warning log message in MQClientInstance (#2294)
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 3eaabee [ISSUE #2293] Add clientID for warning log message in MQClientInstance (#2294)
3eaabee is described below
commit 3eaabeef19b4d68950912b9c9e0d3469b29a5948
Author: Jaskey <li...@gmail.com>
AuthorDate: Sat Sep 12 19:39:03 2020 +0800
[ISSUE #2293] Add clientID for warning log message in MQClientInstance (#2294)
---
.../apache/rocketmq/client/impl/factory/MQClientInstance.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index e937ce3..48cc188 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -475,7 +475,7 @@ public class MQClientInstance {
this.lockHeartbeat.unlock();
}
} else {
- log.warn("lock heartBeat, but failed.");
+ log.warn("lock heartBeat, but failed. [{}]", this.clientId);
}
}
@@ -532,7 +532,7 @@ public class MQClientInstance {
final boolean producerEmpty = heartbeatData.getProducerDataSet().isEmpty();
final boolean consumerEmpty = heartbeatData.getConsumerDataSet().isEmpty();
if (producerEmpty && consumerEmpty) {
- log.warn("sending heartbeat, but no consumer and no producer");
+ log.warn("sending heartbeat, but no consumer and no producer. [{}]", this.clientId);
return;
}
@@ -668,7 +668,7 @@ public class MQClientInstance {
return true;
}
} else {
- log.warn("updateTopicRouteInfoFromNameServer, getTopicRouteInfoFromNameServer return null, Topic: {}", topic);
+ log.warn("updateTopicRouteInfoFromNameServer, getTopicRouteInfoFromNameServer return null, Topic: {}. [{}]", topic, this.clientId);
}
} catch (MQClientException e) {
if (!topic.startsWith(MixAll.RETRY_GROUP_TOPIC_PREFIX)) {
@@ -681,7 +681,7 @@ public class MQClientInstance {
this.lockNamesrv.unlock();
}
} else {
- log.warn("updateTopicRouteInfoFromNameServer tryLock timeout {}ms", LOCK_TIMEOUT_MILLIS);
+ log.warn("updateTopicRouteInfoFromNameServer tryLock timeout {}ms. [{}]", LOCK_TIMEOUT_MILLIS, this.clientId);
}
} catch (InterruptedException e) {
log.warn("updateTopicRouteInfoFromNameServer Exception", e);
@@ -893,7 +893,7 @@ public class MQClientInstance {
this.lockHeartbeat.unlock();
}
} else {
- log.warn("lock heartBeat, but failed.");
+ log.warn("lock heartBeat, but failed. [{}]", this.clientId);
}
} catch (InterruptedException e) {
log.warn("unregisterClientWithLock exception", e);