(rocketmq) branch develop updated: [ISSUE #8472] Fix pop message delay due to not notify message arriving after suspend (#8473)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new cd23d6d0d6 [ISSUE #8472] Fix pop message delay due to not notify 
message arriving after suspend (#8473)
cd23d6d0d6 is described below

commit cd23d6d0d646079b75f95c3f9d125473b6305018
Author: lizhimins <707364...@qq.com>
AuthorDate: Thu Aug 1 10:06:53 2024 +0800

    [ISSUE #8472] Fix pop message delay due to not notify message arriving 
after suspend (#8473)
---
 .../org/apache/rocketmq/broker/processor/PopMessageProcessor.java    | 5 +++++
 1 file changed, 5 insertions(+)

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 89b4c39d72..6073023722 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
@@ -431,6 +431,11 @@ public class PopMessageProcessor implements 
NettyRequestProcessor {
                 PollingResult pollingResult = popLongPollingService.polling(
                     ctx, request, new PollingHeader(requestHeader), 
finalSubscriptionData, finalMessageFilter);
                 if (PollingResult.POLLING_SUC == pollingResult) {
+                    if (restNum > 0) {
+                        popLongPollingService.notifyMessageArriving(
+                            requestHeader.getTopic(), 
requestHeader.getQueueId(), requestHeader.getConsumerGroup(),
+                            null, 0L, null, null);
+                    }
                     return null;
                 } else if (PollingResult.POLLING_FULL == pollingResult) {
                     finalResponse.setCode(ResponseCode.POLLING_FULL);