lizhimins commented on code in PR #9142:
URL: https://github.com/apache/rocketmq/pull/9142#discussion_r1921862925
##########
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java:
##########
@@ -662,6 +662,10 @@ public void attachRecallHandle(RemotingCommand request,
MessageExt msg, SendMess
brokerController.getBrokerConfig().getBrokerName(),
timestampStr, MessageClientIDSetter.getUniqID(msg));
responseHeader.setRecallHandle(recallHandle);
}
+
+ if (msg.getProperty(MessageConst.PROPERTY_TIMER_OUT_MS) != null) {
+
responseHeader.setDelayTime(Long.parseLong(msg.getProperty(MessageConst.PROPERTY_TIMER_OUT_MS)));
Review Comment:
原本的定时在 CommitLog 的 hook 里面转换这个标签，写在这里有点分散
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
