add 集群

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

@@ -79,7 +79,7 @@ public class ClusterDeviceMessageConnector extends DeviceMessageConnector {
         if(message instanceof BroadcastMessage){
            return  Flux.fromStream(getAllNode().stream())
                 .flatMap(node-> clusterManager
-                    .getTopic(ClusterMessageType.topicOf(serverId, ClusterMessageType.up))
+                    .getTopic(ClusterMessageType.topicOf(node.getId(), ClusterMessageType.up))
                         .publish(Mono.just(message))
                 )
                 .flatMap(result->result==0?Mono.just(false):Mono.just(true))