From 0dee922def4ea970c9bff2589e779fdc9a12d1fe Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=82=85=E5=86=B2?= <yubao.fyb@alibaba-inc.com>
Date: Tue, 21 Nov 2017 15:46:52 +0800
Subject: [PATCH] #ROCKETMQ-314#   msg send back must sync change process queue
 msg size .

---
 .../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 38b80738c6..cd7d89027e 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;
@@ -101,7 +102,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);
                             }