add 规则引擎集群

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

@@ -171,7 +171,7 @@ public class ClusterUniqueTask implements Task ,Serializable{
                 })
                 .flatMap(ignore->{
                     try {
-                        lock.tryLock(pingTime,TimeUnit.SECONDS);
+                        lock.tryLock(-1,pingTime, TimeUnit.SECONDS);
                     }catch (Exception e){}
                     if (listenDisposable!=null) {
                         //终止监听心跳
@@ -307,7 +307,7 @@ public class ClusterUniqueTask implements Task ,Serializable{
          *
          */
         if(listenDisposable!=null) {
-            return;
+            listenDisposable.dispose();
         }
         listenDisposable = clusterManager.getTopic(pingTopic)
             .subscribePattern()