SubDevMsg

services/emqx-agent/sub_dev.go

@@ -55,7 +55,7 @@ func (d *MqttClient) PublishToMsgToDev(topic string, payload []byte) error {
 
 const (
 	ShareSubTopicPrefix = "$share/sparrow.agent/"
-	TopicConnectStatus  = ShareSubTopicPrefix + "SYS/brokers/+/clients/#"
+	TopicConnectStatus  = ShareSubTopicPrefix + "$SYS/brokers/+/clients/#"
 	TopicThing          = ShareSubTopicPrefix + protocol.TopicHeadThing + "/up/#"
 	TopicOta            = ShareSubTopicPrefix + protocol.TopicHeadOta + "/up/#"
 	TopicConfig         = ShareSubTopicPrefix + protocol.TopicHeadConfig + "/up/#"