in rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java [1131:1142]
public void afterPropertiesSet() throws Exception {
if (producer != null) {
producer.start();
}
if (Objects.nonNull(consumer)) {
try {
consumer.start();
} catch (Exception e) {
log.error("Failed to startup PullConsumer for RocketMQTemplate", e);
}
}
}