haimd/Beetai_Pro
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Xoa phan Unsubcriber

Browse Source
This commit is contained in:
HaiMD
2020-04-07 17:20:07 +07:00
parent 4d54d52cad
commit 11a715ed34
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
S905X_BI/S905X_BI
View File

Binary file not shown.

4
S905X_BI/S905X_BI.go
View File

@@ -312,8 +312,8 @@ func MQTTOnConnectHandler(client mqtt.Client) {
number_resub = number_resub + 1 number_resub = number_resub + 1
file.Write_log("Lostconnect chanel subcriber: MQTT_OnConnectHandler\n", box.Path_log_luncher) file.Write_log("Lostconnect chanel subcriber: MQTT_OnConnectHandler\n", box.Path_log_luncher)
file.Write_log("Number reconnect subcriber msg: "+strconv.Itoa(number_resub)+"\n", box.Path_log_luncher) file.Write_log("Number reconnect subcriber msg: "+strconv.Itoa(number_resub)+"\n", box.Path_log_luncher)
client.Unsubscribe(CmsTopicOut) //client.Unsubscribe(CmsTopicOut)
time.Sleep(10) //time.Sleep(10)
//client.Subscribe(CmsTopicOut, 0, MqttMessageHandler) //client.Subscribe(CmsTopicOut, 0, MqttMessageHandler)
if token := client.Subscribe(CmsTopicOut, 0, MqttMessageHandler); token.Wait() && token.Error() != nil { if token := client.Subscribe(CmsTopicOut, 0, MqttMessageHandler); token.Wait() && token.Error() != nil {
fmt.Println(token.Error()) fmt.Println(token.Error())

2
S905X_BI/scp.txt
View File

@@ -1,2 +1,2 @@
scp -P 2332 -r -o 'ProxyJump dh.duyhai@ssh_tunnel.beetai.com' S905X_BI root@localhost:/root/monitor/check/ scp -P 2466 -r -o 'ProxyJump dh.duyhai@ssh_tunnel.beetai.com' S905X_BI root@localhost:/root/monitor/check/