[rocketmq] 01/11: change fixed 500ms timeout for "putMessage not in lock" log message.

[huangli]

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 <areyo...@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);