From 47561bdd855ab381113d736b5c26a09c08da590b Mon Sep 17 00:00:00 2001
From: hn <72974271+Hen1ng@users.noreply.github.com>
Date: Fri, 8 Apr 2022 19:20:49 +0800
Subject: [PATCH] [ISSUE #3666] fix npe (#4136)

Co-authored-by: hening <ninghe.hn@alibaba-inc.com>
---
 .../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 f11d5f314b..30cf36c509 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);