t0.2.0

2018-12-19 18:17:30 +08:00 · 2018-12-19 18:17:30 +08:00 · ba0ab6ad74
commit ba0ab6ad74
parent 4b9d4cc5b2
1 changed files with 4 additions and 1 deletions
--- a/parser.go
+++ b/parser.go
@ -147,7 +147,10 @@ func (p *Parser) ConfigQueue(yamlpath string) {
 	if err != nil {
 		panic(err)
 	}
-	p.que.Connect()
+
+	if err := p.que.Connect(); err != nil {
+		panic(err)
+	}
 }

 func (p *Parser) GetLogDB() *logdb.LogDB {