[rocketmq-eventbridge] branch main updated: fix pullTimeOut unit

[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 13aa829  fix pullTimeOut unit
13aa829 is described below

commit 13aa82954b35918dce83c35ae6ffb899b84a20ab
Author: qiaoxingxing <qiaoxingxi...@gmail.com>
AuthorDate: Wed Jul 26 15:42:15 2023 +0800

    fix pullTimeOut unit
---
 .../adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java
 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java
index db4633e..4d32dad 100644
--- 
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java
+++ 
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java
@@ -346,7 +346,7 @@ public class RocketMQEventSubscriber extends 
EventSubscriber {
         public void run() {
             while (!stopped) {
                 try {
-                    List<MessageExt> messages = 
pullConsumer.poll(pullBatchSize, Duration.ofSeconds(pullTimeOut));
+                    List<MessageExt> messages = 
pullConsumer.poll(pullBatchSize, Duration.ofMillis(pullTimeOut));
                     for (MessageExt message : messages) {
                         
message.putUserProperty(RuntimeConfigDefine.RUNNER_NAME, runnerName);
                         messageBuffer.put(message);