hot fix:fix redis lose connection problem

This commit is contained in:
hantmac
2019-08-26 10:38:40 +08:00
parent 8aa32c1c79
commit 1507e6724b

View File

@@ -46,12 +46,12 @@ func (c *Subscriber) Connect() {
panic(errors.New("redis connection failed too many times, panic"))
}
con, err := GetRedisConn()
i += 1
if err != nil {
log.Error("redis dial failed")
continue
}
c.client = redis.PubSubConn{Conn: con}
i += 1
continue
}