diff --git a/parser.go b/parser.go
index 345e65a..5b36126 100644
--- 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 {