add 自动启动

jetlinks-manager/bridge-manager/src/main/java/org/jetlinks/community/bridge/service/AliBridgeService.java

@@ -1,14 +1,17 @@
 package org.jetlinks.community.bridge.service;
 
 import lombok.AllArgsConstructor;
+import org.checkerframework.checker.units.qual.A;
 import org.hswebframework.web.crud.service.GenericReactiveCacheSupportCrudService;
 import org.jetlinks.community.bridge.entity.AliIotBridgeDeviceConfig;
 import org.jetlinks.community.bridge.entity.AliIotBridgeEntity;
 import org.jetlinks.community.bridge.enums.BridgeDeviceStatus;
 import org.jetlinks.community.bridge.enums.BridgeStatus;
 import org.jetlinks.community.bridge.server.aliyun.AliBridgeGateway;
+import org.jetlinks.core.cluster.ClusterManager;
 import org.jetlinks.core.cluster.ClusterUniqueTask;
 import org.jetlinks.supports.cluster.redis.RedisClusterManager;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;
 import reactor.core.publisher.Mono;
@@ -27,7 +30,8 @@ public class AliBridgeService extends GenericReactiveCacheSupportCrudService<Ali
     private final AliBridgeDeviceService bridgeDeviceService;
 
 
-    private final RedisClusterManager clusterManager;
+
+    private final ClusterManager clusterManager;
 
     @Override
     public void run(String... args) {