commit 13aa82954b35918dce83c35ae6ffb899b84a20ab
author qiaoxingxing <QIAOXINGXING2@gmail.com> Wed Jul 26 15:42:15 2023 +0800
committer shenlin <2011shenlin@gmail.com> Wed Aug 16 16:28:13 2023 +0800
tree 688c68da4c550cdfc3cd2c79e6fb2ab7dbf1a3de
parent fc379e09073c8df1fd56fe20972a0f5965352d6f

fix pullTimeOut unit

adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java

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 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);