diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java index 8e3c331aa4ed9536abbd22115e62fcc58f2d3d6a..c49853e943c46ecc57c5529d50b6760af8f391e5 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java @@ -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); }