diff --git a/mqtt_client.go b/mqtt_client.go index 4ba1049..bd0fe1d 100644 --- a/mqtt_client.go +++ b/mqtt_client.go @@ -127,6 +127,7 @@ func messageHandler(client mqtt.Client, msg mqtt.Message) { publishError(client, errorTopic, fmt.Sprintf("❌ DB insert failed: %v", err)) return } + //.. log.Printf("✅ Data inserted successfully for plant ID %d and mfm_meter_id %d", plantID, mfmMeterID)