diff --git a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java index 8a758b58..23b70af8 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java +++ b/rocketmq-v5-client-spring-boot/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/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java index bd301c7b..11ddf854 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtTemplateResetConfiguration.java +++ b/rocketmq-v5-client-spring-boot/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/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java index a6f46402..81c5b091 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java +++ b/rocketmq-v5-client-spring-boot/src/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/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java index fab2d46a..9104828e 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/support/RocketMQUtil.java +++ b/rocketmq-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);