add 规则引擎集群

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

@@ -309,6 +309,9 @@ public class ClusterUniqueTask implements Task ,Serializable{
         if(listenDisposable!=null) {
             listenDisposable.dispose();
         }
+        if(executor!=null){
+            executor.pause();
+        }
         listenDisposable = clusterManager.getTopic(pingTopic)
             .subscribePattern()
             .mergeWith(clusterManager.getTopic(operationTopic).subscribePattern())