You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/02/05 08:56:31 UTC
[rocketmq] branch develop updated: fix ISSUE 2812 (#3813)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 7496081 fix ISSUE 2812 (#3813)
7496081 is described below
commit 7496081da676f4d2cb8f9c2a256a3aa692cdf2bf
Author: Kvicii <42...@users.noreply.github.com>
AuthorDate: Sat Feb 5 16:56:14 2022 +0800
fix ISSUE 2812 (#3813)
---
.../org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 b6e99ba..9afbe9b 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
@@ -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;
}