From ba0ab6ad74ce5d6b7ed63f94cf7337df72efcb80 Mon Sep 17 00:00:00 2001
From: huangsimin <huangsimin@youmi.net>
Date: Wed, 19 Dec 2018 18:17:30 +0800
Subject: [PATCH] t0.2.0

---
 parser.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 {