From 6f5e01e6fa986a78bc82f5054a048159722cd15a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=82=85=E5=86=B2?= Date: Tue, 21 Nov 2017 15:46:52 +0800 Subject: [PATCH] #ROCKETMQ-314# msg send back must sync change process queue msg size . (cherry picked from commit 0dee922) --- .../org/apache/rocketmq/client/impl/consumer/ProcessQueue.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java index e21dbc8f..4176520a 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java @@ -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); } -- GitLab