[GitHub] [rocketmq] horizonzy opened a new issue #2625: Check msg == null when ConsumeMessageConcurrenllyService cleanExpiredMsg().

Sun, 24 Jan 2021 04:55:27 -0800 


horizonzy opened a new issue #2625:
URL: https://github.com/apache/rocketmq/issues/2625


   **FEATURE REQUEST**
   
   1. Please describe the feature you are requesting.
   In ConsumeMessageConcurrenllyService, It will check the msg isn't  consume 
for a long time (15min). 
   If a msg not consume, will send msg back.
   
   If there not exist timeout msg, it still sendMessageBack(msg, 3); 
   
![image](https://user-images.githubusercontent.com/22524871/105630822-2ee01c80-5e86-11eb-8209-2a60d7bda1a1.png)
   
   
   In fact, we can check the msg is null, if null, continue the loop.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to