|
|
|
@ -36,9 +36,6 @@ public class ReceiverStart {
|
|
|
|
|
@Autowired
|
|
|
|
|
private ConsumerFactory consumerFactory;
|
|
|
|
|
|
|
|
|
|
@Value("${austin.nacos.enabled}")
|
|
|
|
|
private Boolean nacosEnabled;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* receiver的消费方法常量
|
|
|
|
|
*/
|
|
|
|
@ -59,13 +56,7 @@ public class ReceiverStart {
|
|
|
|
|
*/
|
|
|
|
|
@PostConstruct
|
|
|
|
|
public void init() {
|
|
|
|
|
int total = groupIds.size();
|
|
|
|
|
if (nacosEnabled) {
|
|
|
|
|
// 当nacos开启时 会导致Receiver提前加载 所以这里getBean次数-1
|
|
|
|
|
// nacos issue: https://github.com/nacos-group/nacos-spring-project/issues/249
|
|
|
|
|
total -= 1;
|
|
|
|
|
}
|
|
|
|
|
for (int i = 0; i < total; i++) {
|
|
|
|
|
for (int i = 0; i < groupIds.size(); i++) {
|
|
|
|
|
context.getBean(Receiver.class);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|