diff --git a/mqtt_client.go b/mqtt_client.go index 2eb6001..bc1bde6 100644 --- a/mqtt_client.go +++ b/mqtt_client.go @@ -205,7 +205,6 @@ func messageHandler(client mqtt.Client, msg mqtt.Message) { return } - // Build insert statement columns := []string{"plant_id", "mfm_meter_id"} placeholders := []string{"$1", "$2"} args := []interface{}{plantID, mfmMeterID}