wn/mqtt-archiver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: wn:0.0.6
Branches Tags
wn:main
wn:0.0.10 wn:0.0.9 wn:0.0.8 wn:0.0.7 wn:0.0.6 wn:0.0.5 wn:0.0.4 wn:0.0.3 wn:0.0.2 wn:0.0.1
..
compare: wn:0.0.9
Branches Tags
wn:main
wn:0.0.10 wn:0.0.9 wn:0.0.8 wn:0.0.7 wn:0.0.6 wn:0.0.5 wn:0.0.4 wn:0.0.3 wn:0.0.2 wn:0.0.1

3 Commits
0.0.6 ... 0.0.9

Author SHA1 Message Date
Wolfgang Hottgenroth
a58959a316 counter fix
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
Details
ci/woodpecker/tag/woodpecker Pipeline was successful
Details
2024-12-02 10:59:29 +01:00
Wolfgang Hottgenroth
2c21ab00a0 counter fix
Some checks failed
ci/woodpecker/push/woodpecker Pipeline failed
Details
ci/woodpecker/tag/woodpecker Pipeline failed
Details
2024-12-02 10:31:11 +01:00
Wolfgang Hottgenroth
d66483cdf3 minimize debug output
Some checks failed
ci/woodpecker/push/woodpecker Pipeline failed
Details
ci/woodpecker/tag/woodpecker Pipeline was successful
Details
2024-12-02 10:26:55 +01:00
1 changed files with 2 additions and 3 deletions
Expand all files Collapse all files

5
src/ma/archiver/archiver.go
View File

@ -7,7 +7,7 @@ import "time"
//import "net/url" //import "net/url"
import "ma/mqtt" import "ma/mqtt"
//import "ma/config" //import "ma/config"
import "ma/counter" //import "ma/counter"
import "ma/database" import "ma/database"
var dbh *database.DatabaseHandle var dbh *database.DatabaseHandle
@ -29,8 +29,7 @@ func InputArchiver() {
} }
func handleMessage(message database.Message) { func handleMessage(message database.Message) {
log.Printf("Archiving Timestamp: %s, Topic: %s, Payload: %s", message.Time, message.Topic, message.Payload) // log.Printf("Archiving Timestamp: %s, Topic: %s, Payload: %s", message.Time, message.Topic, message.Payload)
dbh.StoreMessage(&message) dbh.StoreMessage(&message)
counter.S("Stored")
} }