We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 58c638f commit 8891f94Copy full SHA for 8891f94
rxtx.go
@@ -17,7 +17,6 @@ import (
17
func main() {
18
var port = flag.String("port", "8080", "Server port.")
19
var path = flag.String("path", "./", "Directory to store database.")
20
- //var name = flag.String("name", "rxtx", "Service name.")
21
var interval = flag.Int("interval", 60, "Seconds between intervals.")
22
var batch = flag.Int("batch", 100, "Batch size.")
23
var maxq = flag.Int("maxq", 100000, "Max number of message in queue.")
@@ -35,7 +34,10 @@ func main() {
35
34
return
36
}
37
38
- logger.Sync()
+ err = logger.Sync()
+ if err != nil {
39
+ fmt.Println("WARNING: Logger sync error: " + err.Error())
40
+ }
41
42
logger.Info("Starting rxtx...")
43
0 commit comments