Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
a58959a316
|
|||
2c21ab00a0
|
@ -7,7 +7,7 @@ import "time"
|
||||
//import "net/url"
|
||||
import "ma/mqtt"
|
||||
//import "ma/config"
|
||||
import "ma/counter"
|
||||
//import "ma/counter"
|
||||
import "ma/database"
|
||||
|
||||
var dbh *database.DatabaseHandle
|
||||
@ -31,6 +31,5 @@ func InputArchiver() {
|
||||
func handleMessage(message database.Message) {
|
||||
// log.Printf("Archiving Timestamp: %s, Topic: %s, Payload: %s", message.Time, message.Topic, message.Payload)
|
||||
dbh.StoreMessage(&message)
|
||||
counter.S("Stored")
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user