|
|
@@ -13,6 +13,7 @@ import reactor.core.publisher.Flux;
|
|
|
import reactor.core.publisher.Mono;
|
|
|
import reactor.core.scheduler.Schedulers;
|
|
|
|
|
|
+import javax.annotation.PostConstruct;
|
|
|
import java.time.Duration;
|
|
|
|
|
|
/**
|
|
|
@@ -39,6 +40,7 @@ public class ClusterRuleEngine extends DefaultRuleEngine {
|
|
|
this.serverId = serverId;
|
|
|
}
|
|
|
|
|
|
+ @PostConstruct
|
|
|
public synchronized void init(){
|
|
|
if(started){
|
|
|
return;
|