Skip to content

Commit 07fcb37

Browse files
authored
[ISSUE #718]fix: registers a null consumerBuilder for RocketMQClientTemplate
1 parent fb044e2 commit 07fcb37

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ExtConsumerResetConfiguration.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,8 +96,9 @@ private void registerTemplate(String beanName, Object bean) {
9696

9797
try {
9898
final ClientServiceProvider provider = ClientServiceProvider.loadService();
99-
SimpleConsumerBuilder simpleConsumerBuilder = provider.newSimpleConsumerBuilder();
100-
simpleConsumerInfo = createConsumer(annotation, simpleConsumerBuilder);
99+
consumerBuilder = provider.newSimpleConsumerBuilder();
100+
simpleConsumerInfo = createConsumer(annotation, consumerBuilder);
101+
simpleConsumer = consumerBuilder.build();
101102
} catch (Exception e) {
102103
log.error("Failed to startup SimpleConsumer for RocketMQTemplate {}", beanName, e);
103104
}

0 commit comments

Comments
 (0)