study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

update orderly message log level to info

Browse Source
This commit is contained in:
xiejiashuai 2019-08-13 10:07:16 +08:00
parent 5bbbad0054
commit 2c35e13f5e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream-binder-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/consuming/RocketMQListenerBindingContainer.java
View File

@ -408,7 +408,7 @@ public class RocketMQListenerBindingContainer
long now = System.currentTimeMillis(); long now = System.currentTimeMillis();
rocketMQListener.onMessage(convertToSpringMessage(messageExt)); rocketMQListener.onMessage(convertToSpringMessage(messageExt));
long costTime = System.currentTimeMillis() - now; long costTime = System.currentTimeMillis() - now;
log.debug("consume {} message key:[{}] cost: {} ms", log.info("consume {} message key:[{}] cost: {} ms",
messageExt.getMsgId(), messageExt.getKeys(), costTime); messageExt.getMsgId(), messageExt.getKeys(), costTime);
} }
catch (Exception e) { catch (Exception e) {