Merge pull request #397 from yaziming/forked_develop2

fix(backend): redis sub error
This commit is contained in:
Marvin Zhang
2019-12-25 15:48:11 +08:00
committed by GitHub

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)