Fixed disque typo timeout handling

This commit is contained in:
w1n2k 2017-01-11 09:06:19 +03:00
parent b55721a6c0
commit 872f4c95b2

View File

@ -35,7 +35,7 @@ func (conn *DisqueEndpointConn) Expired() bool {
conn.mu.Lock()
defer conn.mu.Unlock()
if !conn.ex {
if time.Now().Sub(conn.t) > httpExpiresAfter {
if time.Now().Sub(conn.t) > disqueExpiresAfter {
if conn.conn != nil {
conn.close()
}