You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/04/08 11:21:07 UTC
[rocketmq] branch develop updated: [ISSUE #3666] fix npe (#4136)
This is an automated email from the ASF dual-hosted git repository.
yuzhou 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 47561bdd8 [ISSUE #3666] fix npe (#4136)
47561bdd8 is described below
commit 47561bdd855ab381113d736b5c26a09c08da590b
Author: hn <72...@users.noreply.github.com>
AuthorDate: Fri Apr 8 19:20:49 2022 +0800
[ISSUE #3666] fix npe (#4136)
Co-authored-by: hening <ni...@alibaba-inc.com>
---
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index f11d5f314..30cf36c50 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -1554,7 +1554,7 @@ public class DefaultMessageStore implements MessageStore {
return false;
}
Map<String, String> prop = dispatchRequest.getPropertiesMap();
- if (prop == null && prop.isEmpty()) {
+ if (prop == null || prop.isEmpty()) {
return false;
}
String multiDispatchQueue = prop.get(MessageConst.PROPERTY_INNER_MULTI_DISPATCH);