opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #4629 from fujian-zfj/develop-1

Browse Source 
[ISSUE #4628] Fix bug in LMQ when checking multiple Dispatch Queue
This commit is contained in:
Heng Du
2022-07-18 20:02:30 +08:00
committed by GitHub
parent d930cb96ad edf2ee00a6
commit f751fc313c
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
+1 -1
View File
@@ -480,7 +480,7 @@ public class ConsumeQueue implements ConsumeQueueInterface, FileQueueLifeCycle {
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);