add 规则引擎集群

jetlinks-components/rule-engine-component/src/main/java/org/jetlinks/community/rule/engine/cluster/ClusterUniqueTask.java

@@ -94,6 +94,7 @@ class ClusterUniqueTask implements Task ,Serializable{
     private transient Disposable handleDisposable =null;
 
     private transient Disposable generatePingMsgDisposable =null;
+
     /**
      * 持有锁的线程
      */
@@ -191,6 +192,9 @@ class ClusterUniqueTask implements Task ,Serializable{
                     if(State.running.equals(taskState)&&!State.running.equals(executor.getState())){
                         executor.start();
                     }
+                    if(!handleDisposable.isDisposed()){
+                        handleDisposable.dispose();
+                    }
                     if(generatePingMsgDisposable==null||generatePingMsgDisposable.isDisposed()){
                         generatePingMsgDisposable = clusterManager.getTopic(pingTopic).publish(Mono.just(this)).subscribe();
                     }