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

Merge pull request #196 from fuyou001/ROCKETMQ-314-1

Browse Source 
[ROCKETMQ-314] msg send back must sync change process queue msg size
This commit is contained in:
yukon
2017-12-08 17:43:50 +08:00
committed by GitHub
parent cbe5197b35 6f5e01e6fa
commit 6b408ec01a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
+2 -1
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.client.impl.consumer;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
@@ -102,7 +103,7 @@ public class ProcessQueue {
try {
if (!msgTreeMap.isEmpty() && msg.getQueueOffset() == msgTreeMap.firstKey()) {
try {
msgTreeMap.remove(msgTreeMap.firstKey());
removeMessage(Collections.singletonList(msg));
} catch (Exception e) {
log.error("send expired msg exception", e);
}