diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
index f54d20bf87..333b20cecd 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
@@ -176,6 +176,7 @@ public class PopMessageProcessor implements NettyRequestProcessor {
         PopRequest popRequest = remotingCommands.pollFirst();
         //clean inactive channel
         while (popRequest != null && !popRequest.getChannel().isActive()) {
+            totalPollingNum.decrementAndGet();
             popRequest = remotingCommands.pollFirst();
         }