Trying to diagnose memory leak

h00s-go · Jan 21, 2024 · ffca496 · ffca496
1 parent 269b71a
commit ffca496
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/mqtt/mqtt.go b/mqtt/mqtt.go
@@ -52,14 +52,12 @@ func NewMQTT(c *config.MQTT) *MQTT {
 }
 
 func (m *MQTT) Publish(topic string, message string) {
-	go func() {
-		if m.client.IsConnected() {
-			if token := m.client.Publish(topic, 0, false, message); token.Error() != nil {
-				log.Println(token.Error())
-			}
-			log.Println("Published to MQTT topic: ", topic)
+	if m.client.IsConnected() {
+		if token := m.client.Publish(topic, 0, false, message); token.Error() != nil {
+			log.Println(token.Error())
 		}
-	}()
+		log.Println("Published to MQTT topic: ", topic)
+	}
 }
 
 func (m *MQTT) Close() {