You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2021/12/01 10:37:52 UTC
[rocketmq] 01/11: change fixed 500ms timeout for "putMessage not in lock" log message.
This is an automated email from the ASF dual-hosted git repository.
huangli pushed a commit to branch 4.9.2_dev_community
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 44a9172803191a4ba42936eba2e3fea6d1f4feea
Author: huangli <ar...@gmail.com>
AuthorDate: Wed Oct 21 09:51:24 2020 +0800
change fixed 500ms timeout for "putMessage not in lock" log message.
---
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index ed882aa..7f4fcc8 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -436,7 +436,7 @@ public class DefaultMessageStore implements MessageStore {
putResultFuture.thenAccept((result) -> {
long elapsedTime = this.getSystemClock().now() - beginTime;
- if (elapsedTime > 500) {
+ if (elapsedTime > brokerConfig.getWaitTimeMillsInSendQueue()) {
log.warn("putMessage not in lock elapsed time(ms)={}, bodyLength={}", elapsedTime, msg.getBody().length);
}
this.storeStatsService.setPutMessageEntireTimeMax(elapsedTime);