|
|
@@ -90,7 +90,6 @@ public class AliBridgeServer extends AbstractClusterUniqueTask<AliBridgeServer>
|
|
|
//参数发生改变,更新bootstrap
|
|
|
if(!this.params.equals(params)){
|
|
|
verify(params);
|
|
|
- this.params=params;
|
|
|
refreshBridgeConfig(params);
|
|
|
if(broadcast){
|
|
|
//发送广播消息
|
|
|
@@ -105,8 +104,10 @@ public class AliBridgeServer extends AbstractClusterUniqueTask<AliBridgeServer>
|
|
|
bootstrap=new DefaultBridgeBootstrap(params.getId(),bridgeConfigManager);
|
|
|
}
|
|
|
if(bootstrap==null){
|
|
|
+ refreshBridgeConfig(params);
|
|
|
bootstrap=new DefaultBridgeBootstrap(params.getId(),bridgeConfigManager);
|
|
|
}
|
|
|
+ this.params=params;
|
|
|
//非主节点、非运行状态、已启动
|
|
|
if(isReplica()||(!BridgeStatus.running.equals(params.getState())&&!BridgeStatus.starting.equals(params.getState()))||start.get()){
|
|
|
return Mono.just(this);
|