(rocketmq-spring) branch master updated: [ISSUE #718]fix: registers a null consumerBuilder for RocketMQClientTemplate

[jinrongtong]

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

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new 07fcb37  [ISSUE #718]fix: registers a null consumerBuilder for 
RocketMQClientTemplate
07fcb37 is described below

commit 07fcb37a4c7b10472a87d4af43b03eeef8ca8785
Author: Xu Qiaolun <james...@gmail.com>
AuthorDate: Fri Jun 13 14:34:10 2025 +0800

    [ISSUE #718]fix: registers a null consumerBuilder for RocketMQClientTemplate
---
 .../rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 35837c6..8f65b40 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
@@ -96,8 +96,9 @@ public class ExtConsumerResetConfiguration implements 
ApplicationContextAware, S
 
         try {
             final ClientServiceProvider provider = 
ClientServiceProvider.loadService();
-            SimpleConsumerBuilder simpleConsumerBuilder = 
provider.newSimpleConsumerBuilder();
-            simpleConsumerInfo = createConsumer(annotation, 
simpleConsumerBuilder);
+            consumerBuilder = provider.newSimpleConsumerBuilder();
+            simpleConsumerInfo = createConsumer(annotation, consumerBuilder);
+            simpleConsumer = consumerBuilder.build();
         } catch (Exception e) {
             log.error("Failed to startup SimpleConsumer for RocketMQTemplate 
{}", beanName, e);
         }