Merge pull request #170 from hantmac/master

hot fix:fix redis lose connection problem
This commit is contained in:
Marvin Zhang
2019-08-26 10:44:57 +08:00
committed by GitHub

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
}