fix(backend):

修复redis连接池订阅消息失败时,因为ping操作优先获取到错误造成chain提前关闭引发panic的问题
This commit is contained in:
yaziming
2019-12-25 14:02:45 +08:00
parent b883656621
commit 086d50f512

View File

@@ -58,9 +58,9 @@ func (r *Redis) subscribe(ctx context.Context, consume ConsumeFunc, channel ...s
}
done <- nil
case <-tick.C:
//fmt.Printf("ping message \n")
if err := psc.Ping(""); err != nil {
done <- err
fmt.Printf("ping message error: %s \n", err)
//done <- err
}
case err := <-done:
close(done)