|
|
@@ -39,7 +39,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
* @createTime 2021年11月30日 11:01:00
|
|
|
*/
|
|
|
@Slf4j
|
|
|
-public class AliBridgeServer extends ClusterUniqueTask implements BridgeServer {
|
|
|
+public class AliBridgeServer implements BridgeServer {
|
|
|
private Map<String, Channel> channelMap=new ConcurrentHashMap<>();
|
|
|
|
|
|
private final EventBus eventBus;
|
|
|
@@ -62,7 +62,6 @@ public class AliBridgeServer extends ClusterUniqueTask implements BridgeServer
|
|
|
private final String id;
|
|
|
private final DeviceRegistry deviceRegistry;
|
|
|
private AliBridgeServer(EventBus eventBus, DeviceRegistry deviceRegistry, String clusterId, String id) {
|
|
|
- super("",null,null);
|
|
|
this.deviceRegistry=deviceRegistry;
|
|
|
this.eventBus = eventBus;
|
|
|
this.clusterId=clusterId;
|
|
|
@@ -206,24 +205,4 @@ public class AliBridgeServer extends ClusterUniqueTask implements BridgeServer
|
|
|
return receive;
|
|
|
}
|
|
|
|
|
|
-
|
|
|
- @Override
|
|
|
- public void beMasterPostProcessor() {
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Mono<?> handleMsg(Object msg) {
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public void beforeHandleMsg() {
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Mono<Void> handlePing(ClusterUniqueTask task) {
|
|
|
- return null;
|
|
|
- }
|
|
|
}
|