mirror of
https://github.com/apache/rocketmq.git
synced 2026-10-30 18:44:38 +08:00
[#1540] add comment
This commit is contained in:
+1
-1
@@ -1180,7 +1180,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
|
||||
throw new MQClientException("tranExecutor is null", null);
|
||||
}
|
||||
|
||||
// 事务消息屏蔽DelayTimeLevel参数
|
||||
// ignore DelayTimeLevel parameter
|
||||
if(msg.getDelayTimeLevel() != 0) {
|
||||
MessageAccessor.clearProperty(msg, MessageConst.PROPERTY_DELAY_TIME_LEVEL);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user