add 规则引擎集群

jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/cluster/ClusterDeviceMessageConnector.java

@@ -90,6 +90,7 @@ public class ClusterDeviceMessageConnector extends DeviceMessageConnector {
                                 msg.getPayload());
                         })
                         .doOnError(e -> log.error("集群信息接收失败,节点关闭{};", serverId,e))
+                        .doFinally(e->log.info("信息集群节点关闭{}",serverId))
                         .subscribe();
                     log.info("集群节点重启{}成功",serverId);
                 }