fix ISSUE 2812 (#3813)

2026-09-24 16:04:00 +08:00 · 2022-02-05 16:56:14 +08:00
parent f219170851
commit 7496081da6
1 changed files with 1 additions and 1 deletions
@@ -732,7 +732,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
                }

                final String tranMsg = msg.getProperty(MessageConst.PROPERTY_TRANSACTION_PREPARED);
-                if (tranMsg != null && Boolean.parseBoolean(tranMsg)) {
+                if (Boolean.parseBoolean(tranMsg)) {
                    sysFlag |= MessageSysFlag.TRANSACTION_PREPARED_TYPE;
                }