[ISSUE #610] fix setRequestTimeout use Duration.ofDays (#621)

Co-authored-by: rongtong <jinrongtong5@163.com>
apache · Feb 9, 2024 · 251a53e · 251a53e
1 parent 89896c5
commit 251a53e
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/...src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java b/...src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java
@@ -115,7 +115,7 @@ private SimpleConsumerBuilder createConsumer(org.apache.rocketmq.client.annotati
         String endPoints = resolvePlaceholders(annotation.endpoints(), simpleConsumer.getEndpoints());
         String tag = resolvePlaceholders(annotation.tag(), simpleConsumer.getTag());
         String filterExpressionType = resolvePlaceholders(annotation.filterExpressionType(), simpleConsumer.getFilterExpressionType());
-        Duration requestTimeout = Duration.ofDays(annotation.requestTimeout());
+        Duration requestTimeout = Duration.ofSeconds(annotation.requestTimeout());
         int awaitDuration = annotation.awaitDuration();
         Boolean sslEnabled = simpleConsumer.isSslEnabled();
         Assert.hasText(topicName, "[topic] must not be null");

diff --git a/...src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java b/...src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java
@@ -112,7 +112,7 @@ private ProducerBuilder createProducer(ExtProducerResetConfiguration annotation)
         secretKey = StringUtils.hasLength(secretKey) ? secretKey : producerConfig.getSecretKey();
         int requestTimeout = annotation.requestTimeout();
         Boolean sslEnabled = producerConfig.isSslEnabled();
-        ClientConfiguration clientConfiguration = RocketMQUtil.createClientConfiguration(accessKey, secretKey, endpoints, Duration.ofDays(requestTimeout), sslEnabled);
+        ClientConfiguration clientConfiguration = RocketMQUtil.createClientConfiguration(accessKey, secretKey, endpoints, Duration.ofSeconds(requestTimeout), sslEnabled);
         final ClientServiceProvider provider = ClientServiceProvider.loadService();
         ProducerBuilder producerBuilder = provider.newProducerBuilder()
                 .setClientConfiguration(clientConfiguration).setMaxAttempts(annotation.maxAttempts())

diff --git a/...rc/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java b/...rc/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java
@@ -90,7 +90,7 @@ private DefaultListenerContainer createRocketMQListenerContainer(String name, Ob
         container.setTag(environment.resolvePlaceholders(annotation.tag()));
         container.setEndpoints(environment.resolvePlaceholders(annotation.endpoints()));
         container.setTopic(environment.resolvePlaceholders(annotation.topic()));
-        container.setRequestTimeout(Duration.ofDays(annotation.requestTimeout()));
+        container.setRequestTimeout(Duration.ofSeconds(annotation.requestTimeout()));
         container.setMaxCachedMessageCount(annotation.maxCachedMessageCount());
         container.setConsumptionThreadCount(annotation.consumptionThreadCount());
         container.setMaxCacheMessageSizeInBytes(annotation.maxCacheMessageSizeInBytes());

diff --git a/...-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java b/...-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java
@@ -120,7 +120,7 @@ public static ClientConfiguration createProducerClientConfiguration(RocketMQProp
         String accessKey = rocketMQProducer.getAccessKey();
         String secretKey = rocketMQProducer.getSecretKey();
         String endPoints = rocketMQProducer.getEndpoints();
-        Duration requestTimeout = Duration.ofDays(rocketMQProducer.getRequestTimeout());
+        Duration requestTimeout = Duration.ofSeconds(rocketMQProducer.getRequestTimeout());
         boolean sslEnabled = rocketMQProducer.isSslEnabled();
         return createClientConfiguration(accessKey, secretKey, endPoints, requestTimeout, sslEnabled);
     }
@@ -129,7 +129,7 @@ public static ClientConfiguration createConsumerClientConfiguration(RocketMQProp
         String accessKey = simpleConsumer.getAccessKey();
         String secretKey = simpleConsumer.getSecretKey();
         String endPoints = simpleConsumer.getEndpoints();
-        Duration requestTimeout = Duration.ofDays(simpleConsumer.getRequestTimeout());
+        Duration requestTimeout = Duration.ofSeconds(simpleConsumer.getRequestTimeout());
         boolean sslEnabled = simpleConsumer.isSslEnabled();
         return createClientConfiguration(accessKey, secretKey, endPoints, requestTimeout, sslEnabled);