poc/mqtt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: poc:f6d3908088f5de7cd8a7cd4d4edb5ca57319b3c9
Branches Tags
poc:master poc:dev-mqtt
...
compare: poc:dev-mqtt
Branches Tags
poc:master poc:dev-mqtt

4 Commits
f6d3908088 ... dev-mqtt

Author SHA1 Message Date
jothi
acec9d72b4 Merge branch 'master' into dev-mqtt 2025-08-06 05:51:44 +00:00
jothi
64a8a32d1a removed unwanted line for checking branch 2025-08-06 05:40:39 +00:00
jothi
89786c9dfa Merge pull request 'Remove commented line for checking git branch' (#1) from dev-mqtt into master 
Reviewed-on: #1
 2025-08-06 05:28:29 +00:00
jothi
bd68af1f58 Remove commented line for checking git branch 2025-08-06 05:17:46 +00:00
1 changed files with 0 additions and 3 deletions
Expand all files Collapse all files

3
mqtt_client.go
View File

@@ -205,7 +205,6 @@ func messageHandler(client mqtt.Client, msg mqtt.Message) {
return return
} }
// Build insert statement
columns := []string{"plant_id", "mfm_meter_id"} columns := []string{"plant_id", "mfm_meter_id"}
placeholders := []string{"$1", "$2"} placeholders := []string{"$1", "$2"}
args := []interface{}{plantID, mfmMeterID} args := []interface{}{plantID, mfmMeterID}
@@ -255,8 +254,6 @@ func connectionLostHandler(client mqtt.Client, err error) {
log.Printf("Connection lost: %v. Attempting to reconnect...", err) log.Printf("Connection lost: %v. Attempting to reconnect...", err)
} }
//..
func main() { func main() {
var err error var err error
godotenv.Load() godotenv.Load()