|
@@ -319,10 +319,11 @@ public class AliBridgeServer extends AbstractClusterUniqueTask<AliBridgeServer>
|
|
|
@Override
|
|
@Override
|
|
|
public void beMasterPostProcessor() {
|
|
public void beMasterPostProcessor() {
|
|
|
handleStatus(this.params.getState(),false)
|
|
handleStatus(this.params.getState(),false)
|
|
|
- .flatMap(ignore->
|
|
|
|
|
- bridgeService.createUpdate()
|
|
|
|
|
- .set(AliIotBridgeEntity::getNodeId,this.getCurrentSeverId())
|
|
|
|
|
- .execute()).subscribe();
|
|
|
|
|
|
|
+ .concatWith(bridgeService.createUpdate()
|
|
|
|
|
+ .set(AliIotBridgeEntity::getNodeId,this.getCurrentSeverId())
|
|
|
|
|
+ .execute()
|
|
|
|
|
+ .then()
|
|
|
|
|
+ ).subscribe();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|