This commit is contained in:
huangsimin 2018-12-19 18:20:03 +08:00
parent 95d9d6442a
commit 81e2294dd7

View File

@ -143,11 +143,13 @@ func (p *Parser) ConfigQueue(yamlpath string) {
if err != nil {
panic(err)
}
err = yaml.Unmarshal(data, p.que)
if err != nil {
panic(err)
}
log.Println(p.que)
if err := p.que.Connect(); err != nil {
panic(err)
}