diff --git a/GPIO/GPIO.go b/GPIO/GPIO.go index 19524ae..8146f29 100644 --- a/GPIO/GPIO.go +++ b/GPIO/GPIO.go @@ -156,7 +156,7 @@ func main() { fmt.Println(door) mqtt_begin() //SetConnectionLostHandler(connLostHandler) - mqtt_cms_bi.Subscribe(CMS_TOPIC_IN, 0, mqtt_messageHandler) + //mqtt_cms_bi.Subscribe(CMS_TOPIC_IN, 0, mqtt_messageHandler) // Open and map memory to access gpio, check for errors if err := rpio.Open(); err != nil { @@ -196,14 +196,25 @@ func mqtt_begin() { fmt.Println(CMS_HOST_BI) fmt.Println(CMS_ACCESS_TOKEN_BI) fmt.Println(CMS_PASS_BI) + opts_cms_bi := mqtt.NewClientOptions() opts_cms_bi.AddBroker(CMS_HOST_BI) opts_cms_bi.SetUsername(CMS_ACCESS_TOKEN_BI) opts_cms_bi.SetPassword(CMS_PASS_BI) opts_cms_bi.SetCleanSession(true) + opts_cms_bi.OnConnect = func(c mqtt.Client) { + fmt.Printf("Client connected, subscribing to: " + CMS_TOPIC_IN) + c.Subscribe(CMS_TOPIC_IN, 0, mqtt_messageHandler) + } + + opts_cms_bi.OnConnectionLost = (c mqtt.Client, err error) { + fmt.Println("MQTT Lost Connect\n") + fmt.Println(err) + } + mqtt_cms_bi = mqtt.NewClient(opts_cms_bi) - opts_cms_bi.SetConnectionLostHandler(MQTTLostConnectHandler) - opts_cms_bi.SetOnConnectHandler(MQTTOnConnectHandler) + // opts_cms_bi.SetConnectionLostHandler(MQTTLostConnectHandler) + // opts_cms_bi.SetOnConnectHandler(MQTTOnConnectHandler) var reconect = false for reconect == false { @@ -213,38 +224,36 @@ func mqtt_begin() { fmt.Printf("MQTT CMS Beetsoft Connected\n") } reconect = true - } else { - //file.Write_log("MQTT CMS Beetsoft cant not Connected\n", path_log) - if Debug == 1 { - fmt.Printf("MQTT CMS Beetsoft cant not Connected\n") - fmt.Printf("Loi CMS Beetsoft : %v \n", token_1.Error()) - fmt.Printf("-------------------\n") - } - reconect = false } + // else { + // //file.Write_log("MQTT CMS Beetsoft cant not Connected\n", path_log) + // if Debug == 1 { + // fmt.Printf("MQTT CMS Beetsoft cant not Connected\n") + // fmt.Printf("Loi CMS Beetsoft : %v \n", token_1.Error()) + // fmt.Printf("-------------------\n") + // } + // reconect = false + // } } - opts_cms_bi.OnConnect = func(c mqtt.Client) { - fmt.Printf("Client connected, subscribing to: " + CMS_TOPIC_IN) - c.Subscribe(CMS_TOPIC_IN, 0, mqtt_messageHandler) - } + } -func MQTTLostConnectHandler(c mqtt.Client, err error) { - // file.Write_log("MQTT CMS Beetsoft Lost Connect\n", box.Path_log_luncher) - fmt.Println("MQTT CMS Beetsoft Lost Connect\n") - fmt.Println(err) -} -func MQTTOnConnectHandler(client mqtt.Client) { - // file.Write_log("Reconnect: MQTT_OnConnectHandler\n", box.Path_log_luncher) - fmt.Println("Reconnect: MQTT_OnConnectHandler\n") - mqtt_cms_bi.Unsubscribe(CMS_TOPIC_IN) - time.Sleep(10) - mqtt_cms_bi.Subscribe(CMS_TOPIC_IN, 0, mqtt_messageHandler) - fmt.Println("Recall function Subscribe MQTT\n") - // file.Write_log("Recall function Subscribe MQTT\n", box.Path_log_luncher) -} +// func MQTTLostConnectHandler(c mqtt.Client, err error) { +// // file.Write_log("MQTT CMS Beetsoft Lost Connect\n", box.Path_log_luncher) +// fmt.Println("MQTT CMS Beetsoft Lost Connect\n") +// fmt.Println(err) +// } +// func MQTTOnConnectHandler(client mqtt.Client) { +// // file.Write_log("Reconnect: MQTT_OnConnectHandler\n", box.Path_log_luncher) +// fmt.Println("Reconnect: MQTT_OnConnectHandler\n") +// mqtt_cms_bi.Unsubscribe(CMS_TOPIC_IN) +// time.Sleep(10) +// mqtt_cms_bi.Subscribe(CMS_TOPIC_IN, 0, mqtt_messageHandler) +// fmt.Println("Recall function Subscribe MQTT\n") +// // file.Write_log("Recall function Subscribe MQTT\n", box.Path_log_luncher) +// } /************************************************************************/ var k int