提交 6f5e01e6 编写于 作者: 傅冲

#ROCKETMQ-314# msg send back must sync change process queue msg size .

(cherry picked from commit 0dee922)
上级 6f0c9966
...@@ -17,6 +17,7 @@ ...@@ -17,6 +17,7 @@
package org.apache.rocketmq.client.impl.consumer; package org.apache.rocketmq.client.impl.consumer;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.TreeMap; import java.util.TreeMap;
...@@ -102,7 +103,7 @@ public class ProcessQueue { ...@@ -102,7 +103,7 @@ public class ProcessQueue {
try { try {
if (!msgTreeMap.isEmpty() && msg.getQueueOffset() == msgTreeMap.firstKey()) { if (!msgTreeMap.isEmpty() && msg.getQueueOffset() == msgTreeMap.firstKey()) {
try { try {
msgTreeMap.remove(msgTreeMap.firstKey()); removeMessage(Collections.singletonList(msg));
} catch (Exception e) { } catch (Exception e) {
log.error("send expired msg exception", e); log.error("send expired msg exception", e);
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册