fix: message was only sent each 5 minutes

kpetremann · Jun 23, 2023 · 29cfc1c · 29cfc1c
1 parent fc6f382
commit 29cfc1c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cmd/dht2mqtt/main.go b/cmd/dht2mqtt/main.go
@@ -17,7 +17,7 @@ func watchAndPublish(sensorName string, publisher mqtt.Publisher, ch <-chan sens
 	var lastPayload sensor.Payload
 	lastChange := time.Now()
 	for sensorPayload := range ch {
-		if sensorPayload.EqualTo(lastPayload) || time.Since(lastChange) > 5*time.Minute {
+		if !sensorPayload.EqualTo(lastPayload) || time.Since(lastChange) > 5*time.Minute {
 			lastPayload = sensorPayload
 			err := publisher.Publish(sensorName, sensorPayload)
 			if err != nil {