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/06/06 03:18:16 UTC
[rocketmq] branch develop updated: [ISSUE #4377]Unnecessary null check before method call (#4378)
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 7973f9ee5 [ISSUE #4377]Unnecessary null check before method call (#4378)
7973f9ee5 is described below
commit 7973f9ee5eb905fd2da69b91382d6e01c18c16ab
Author: CoderBruis <37...@users.noreply.github.com>
AuthorDate: Mon Jun 6 11:18:11 2022 +0800
[ISSUE #4377]Unnecessary null check before method call (#4378)
* Update .travis.yml
Depracated MODERATE noisy mail for dev@rocketmq.apache.org. Still Failing: apache/rocketmq#5670 (5.0.0-alpha-static-topic - 5ebc327) @dongeforever
* Updated Notice file to 2022 (#3735)
* Unnecessary_null_check_before_method_call
Co-authored-by: von gosling <vo...@apache.org>
Co-authored-by: ZhangJian He <sh...@gmail.com>
Co-authored-by: tigerweili <ti...@tencent.com>
---
.../org/apache/rocketmq/broker/processor/SendMessageProcessor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
index f98b58d3e..6d10276a4 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -314,7 +314,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
CompletableFuture<PutMessageResult> putMessageResult = null;
String transFlag = origProps.get(MessageConst.PROPERTY_TRANSACTION_PREPARED);
- if (transFlag != null && Boolean.parseBoolean(transFlag)) {
+ if (Boolean.parseBoolean(transFlag)) {
if (this.brokerController.getBrokerConfig().isRejectTransactionMessage()) {
response.setCode(ResponseCode.NO_PERMISSION);
response.setRemark(
@@ -445,7 +445,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
PutMessageResult putMessageResult = null;
Map<String, String> oriProps = MessageDecoder.string2messageProperties(requestHeader.getProperties());
String traFlag = oriProps.get(MessageConst.PROPERTY_TRANSACTION_PREPARED);
- if (traFlag != null && Boolean.parseBoolean(traFlag)
+ if (Boolean.parseBoolean(traFlag)
&& !(msgInner.getReconsumeTimes() > 0 && msgInner.getDelayTimeLevel() > 0)) { //For client under version 4.6.1
if (this.brokerController.getBrokerConfig().isRejectTransactionMessage()) {
response.setCode(ResponseCode.NO_PERMISSION);