소스 검색

change 指令下发改为异步进行

18339543638 4 년 전
부모
커밋
113b9f3bdd
1개의 변경된 파일1개의 추가작업 그리고 0개의 파일을 삭제
  1. 1 0
      jetlinks-core/src/main/java/org/jetlinks/core/cluster/ClusterUniqueTask.java

+ 1 - 0
jetlinks-core/src/main/java/org/jetlinks/core/cluster/ClusterUniqueTask.java

@@ -70,6 +70,7 @@ public abstract class ClusterUniqueTask implements Serializable {
     public ClusterUniqueTask(String id,String currentSeverId,
                           ClusterManager clusterManager,
                           RedissonClient redissonClient) {
+        this.id=id;
         this.currentSeverId=currentSeverId;
         this.workerId=currentSeverId;
         this.clusterManager=clusterManager;