ExtConsumerResetConfiguration.java 中的 registerTemplate 方法存在问题

[gotoxu]

代码片段

    SimpleConsumerBuilder consumerBuilder = null;
    SimpleConsumer simpleConsumer = null;
    SimpleConsumerInfo simpleConsumerInfo = null;


    try {
        final ClientServiceProvider provider = ClientServiceProvider.loadService();
        SimpleConsumerBuilder simpleConsumerBuilder = provider.newSimpleConsumerBuilder();
        simpleConsumerInfo = createConsumer(annotation, simpleConsumerBuilder);
    } catch (Exception e) {
        log.error("Failed to startup SimpleConsumer for RocketMQTemplate {}", beanName, e);
    }
    RocketMQClientTemplate rocketMQTemplate = (RocketMQClientTemplate) bean;
    rocketMQTemplate.setSimpleConsumerBuilder(consumerBuilder);
    rocketMQTemplate.setSimpleConsumer(simpleConsumer);

这里是否应改成：

SimpleConsumerBuilder consumerBuilder = null;
SimpleConsumer simpleConsumer = null;
SimpleConsumerInfo simpleConsumerInfo = null;

try {
  final ClientServiceProvider provider = ClientServiceProvider.loadService();
  consumerBuilder = provider.newSimpleConsumerBuilder();
  simpleConsumerInfo = createConsumer(annotation, consumerBuilder);
  simpleConsumer = consumerBuilder.build();
} catch (Exception e) {
  log.error("Failed to startup SimpleConsumer for RocketMQTemplate {}", beanName, e);
}

RocketMQClientTemplate rocketMQClient = (RocketMQClientTemplate) bean;
rocketMQClient.setConsumerBuilder(consumerBuilder);
rocketMQClient.setConsumer(simpleConsumer );

请确认一下

[panzhi33]

没看出有问题

[tangzhen7789]

我也遇到同样的问题 extConsumerResetConfiguration 构建template时 将 builder 置为null了

[wanghongzhou]

[panzhi33]

是的，这里有问题。可以提交割pr修复下