|
@@ -104,6 +104,9 @@ public class AliBridgeServer extends AbstractClusterUniqueTask<AliBridgeServer>
|
|
|
}
|
|
}
|
|
|
bootstrap=new DefaultBridgeBootstrap(params.getId(),bridgeConfigManager);
|
|
bootstrap=new DefaultBridgeBootstrap(params.getId(),bridgeConfigManager);
|
|
|
}
|
|
}
|
|
|
|
|
+ if(bootstrap==null){
|
|
|
|
|
+ bootstrap=new DefaultBridgeBootstrap(params.getId(),bridgeConfigManager);
|
|
|
|
|
+ }
|
|
|
//非主节点、非运行状态、已启动
|
|
//非主节点、非运行状态、已启动
|
|
|
if(isReplica()||(!BridgeStatus.running.equals(params.getState())&&!BridgeStatus.starting.equals(params.getState()))||start.get()){
|
|
if(isReplica()||(!BridgeStatus.running.equals(params.getState())&&!BridgeStatus.starting.equals(params.getState()))||start.get()){
|
|
|
return Mono.just(this);
|
|
return Mono.just(this);
|