commit
a63cd20703
@ -35,7 +35,7 @@ func (conn *DisqueEndpointConn) Expired() bool {
|
|||||||
conn.mu.Lock()
|
conn.mu.Lock()
|
||||||
defer conn.mu.Unlock()
|
defer conn.mu.Unlock()
|
||||||
if !conn.ex {
|
if !conn.ex {
|
||||||
if time.Now().Sub(conn.t) > httpExpiresAfter {
|
if time.Now().Sub(conn.t) > disqueExpiresAfter {
|
||||||
if conn.conn != nil {
|
if conn.conn != nil {
|
||||||
conn.close()
|
conn.close()
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user