|
@@ -75,8 +75,7 @@ namespace DataVAPI.UpAndDown |
|
|
Subscribe(IOTDevServer.HeartbeatSubTopic); |
|
|
Subscribe(IOTDevServer.HeartbeatSubTopic); |
|
|
|
|
|
|
|
|
//订阅主播消息 |
|
|
//订阅主播消息 |
|
|
Subscribe("/broadcast/grgpECHSL7q/Transit_SetDevice"); |
|
|
|
|
|
Subscribe("/broadcast/grgpECHSL7q/Transit_Test_SetDevice"); |
|
|
|
|
|
|
|
|
Subscribe(IOTDevServer.BroadcastTopic); |
|
|
|
|
|
|
|
|
IOTDevServer.UNConnectMqtt += new Action<string>((o) => { ConsoleHelper.WriteSuccessLine(o); }); |
|
|
IOTDevServer.UNConnectMqtt += new Action<string>((o) => { ConsoleHelper.WriteSuccessLine(o); }); |
|
|
|
|
|
|
|
@@ -317,7 +316,7 @@ namespace DataVAPI.UpAndDown |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
else if (topic == "/broadcast/grgpECHSL7q/Transit_SetDevice" || topic == "/broadcast/grgpECHSL7q/Transit_Test_SetDevice")//广播主题 |
|
|
|
|
|
|
|
|
else if (topic == IOTDevServer.BroadcastTopic)//广播主题 |
|
|
{ |
|
|
{ |
|
|
if (message.Contains("AlarmType")) |
|
|
if (message.Contains("AlarmType")) |
|
|
{ |
|
|
{ |
|
|