|
|
@@ -23,12 +23,10 @@ import reactor.core.scheduler.Schedulers;
|
|
|
public class AliBridgeService extends GenericReactiveCacheSupportCrudService<AliIotBridgeEntity, String> implements CommandLineRunner {
|
|
|
private final AliBridgeGateway bridgeGateway;
|
|
|
private final AliBridgeDeviceService bridgeDeviceService;
|
|
|
- private final ClusterManager clusterManager;
|
|
|
|
|
|
@Override
|
|
|
public void run(String... args) {
|
|
|
this.createQuery()
|
|
|
- .where(AliIotBridgeEntity::getNodeId,clusterManager.getCurrentServerId())
|
|
|
.fetch()
|
|
|
.parallel()
|
|
|
.runOn(Schedulers.parallel())
|