[rocketmq-eventbridge] branch main updated: bugfix:fix rmq local cache full issue

[shenlin]

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

shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git


The following commit(s) were added to refs/heads/main by this push:
     new c11495e  bugfix:fix rmq local cache full issue
c11495e is described below

commit c11495ed80175b01f2f541a5f215e5e865a82672
Author: changfeng <yongming....@alibaba-inc.com>
AuthorDate: Mon Jun 26 13:45:50 2023 +0800

    bugfix:fix rmq local cache full issue
---
 .../adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java
 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java
index 7eda3d9..7636449 100644
--- 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java
+++ 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java
@@ -230,6 +230,7 @@ public class LitePullConsumerImpl implements 
LitePullConsumer {
                     log.warn("Local cache is full, delay the pull task {} ms 
for message queue {}",
                             PULL_TIME_DELAY_MILLS_WHEN_EXCEPTION, 
messageQueue);
                     pullLater(PullTask.this, 
PULL_TIME_DELAY_MILLS_WHEN_EXCEPTION, TimeUnit.MILLISECONDS);
+                    return;
                 }
 
                 rocketmqPullConsumer.pullBlockIfNotFound(this.messageQueue, 
this.tag, offset, batchNums, new PullCallback() {