feat: make check expired message interval configurable to reduce the …

…consuming thread block time

client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java

@@ -288,6 +288,11 @@ public class DefaultMQPushConsumer extends ClientConfig implements MQPushConsume
 
     private RPCHook rpcHook = null;
 
+    /**
+     * Interval to clean expired messages
+     */
+    private long cleanExpiredMsgInterval = 15;
+
     /**
      * Default constructor.
      */
@@ -1002,4 +1007,12 @@ public MessageQueueListener getMessageQueueListener() {
     public void setMessageQueueListener(MessageQueueListener messageQueueListener) {
         this.messageQueueListener = messageQueueListener;
     }
+
+    public long getCleanExpiredMsgInterval() {
+        return cleanExpiredMsgInterval;
+    }
+
+    public void setCleanExpiredMsgInterval(long cleanExpiredMsgInterval) {
+        this.cleanExpiredMsgInterval = cleanExpiredMsgInterval;
+    }
 }

client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java

@@ -94,7 +94,7 @@ public void run() {
                 }
             }
 
-        }, this.defaultMQPushConsumer.getConsumeTimeout(), this.defaultMQPushConsumer.getConsumeTimeout(), TimeUnit.MINUTES);
+        }, this.defaultMQPushConsumer.getCleanExpiredMsgInterval(), this.defaultMQPushConsumer.getCleanExpiredMsgInterval(), TimeUnit.MINUTES);
     }
 
     public void shutdown(long awaitTerminateMillis) {