diff --git a/controller/endpoint/disque.go b/controller/endpoint/disque.go
index cd315fc2..b47ec998 100644
--- a/controller/endpoint/disque.go
+++ b/controller/endpoint/disque.go
@@ -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()
 			}