From 872f4c95b26b08b7de6ef2e848eadab5c187ec07 Mon Sep 17 00:00:00 2001
From: w1n2k <cryfall@gmail.com>
Date: Wed, 11 Jan 2017 09:06:19 +0300
Subject: [PATCH] Fixed disque typo timeout handling

---
 controller/endpoint/disque.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()
 			}