|
|
@@ -97,12 +97,12 @@ public class AliBridgeServer extends ClusterUniqueTask<AliBridgeServer> {
|
|
|
Assert.notNull(http2Endpoint,"创建网桥 http2Endpoint 不能为空, mapping id {%s}",params.getId());
|
|
|
String regionId = accessConfig.getRegionId();
|
|
|
Assert.notNull(regionId,"创建网桥 regionId 不能为空, mapping id {%s}",params.getId());
|
|
|
+ this.params=params;
|
|
|
if(broadcast){
|
|
|
//发送广播消息
|
|
|
getClusterOperationTopic().publish(Mono.just(OperationMessage.builder().param(params).init(true).build())).subscribe();
|
|
|
}
|
|
|
if(isReplica()){
|
|
|
- this.params=params;
|
|
|
return Mono.empty();
|
|
|
}
|
|
|
|