From e55db10c600e86ed6569c9795f6199b98fac7d44 Mon Sep 17 00:00:00 2001
From: zhangyang <zhangyang21@xiaomi.com>
Date: Fri, 6 May 2022 09:28:25 +0800
Subject: [PATCH] [ISSUE #4072] fix totalPollingNum count error (#4073)

Signed-off-by: zhangyang <Git_Yang@163.com>
---
 .../apache/rocketmq/broker/processor/PopMessageProcessor.java    | 1 +
 1 file changed, 1 insertion(+)

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();
         }