fix: updated project structure
This commit is contained in:
parent
78a2f4e650
commit
769ba5b69b
|
|
@ -19,15 +19,13 @@ func main() {
|
|||
|
||||
client := mqttclient.EstablishESPConnection(config)
|
||||
defer client.Disconnect(250)
|
||||
// subscribeToken := mqttclient.RecieveTopics(client)
|
||||
subscribeToken := mqttclient.RecieveTopics(client, "esp32/oliver1/metrics", byte(1))
|
||||
print(subscribeToken)
|
||||
|
||||
if subscribeToken.Wait() && subscribeToken.Error() != nil {
|
||||
slog.Error("Failed to subscribe to topic!", "error", subscribeToken.Error)
|
||||
}
|
||||
// todo: add, revecing message from the broker
|
||||
|
||||
fmt.Println("Programm läuft und hält die Verbindung. Beenden mit Ctrl+C.")
|
||||
print(subscribeToken)
|
||||
select {}
|
||||
}
|
||||
|
|
@ -7,7 +7,6 @@ import (
|
|||
)
|
||||
|
||||
func RecieveTopics(c mqtt.Client, topic string, qos byte) mqtt.Token {
|
||||
// topic = "esp32/oliver1/metrics"
|
||||
token := c.Subscribe(topic, qos, RevieveMessage)
|
||||
token.Wait()
|
||||
fmt.Println("Subscription to the topic succesfully", topic)
|
||||
|
|
|
|||
|
|
@ -1,5 +1,4 @@
|
|||
{
|
||||
"mqtt_server": "8b758ea22b9f4c0f94ac43c9b09a254f.s1.eu.hivemq.cloud",
|
||||
"mqtt_user": "esp32_1",
|
||||
"mqtt_password": "Testuser123"
|
||||
{ "mqtt_server": "8b758ea22b9f4c0f94ac43c9b09a254f.s1.eu.hivemq.cloud",
|
||||
"mqtt_user": "oliver3",
|
||||
"mqtt_password": "tESTUSER1234"
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in a new issue