diff --git a/router/connection.go b/router/connection.go index 35c1d2b5..dc521888 100644 --- a/router/connection.go +++ b/router/connection.go @@ -172,16 +172,15 @@ func (conn *LocalConnection) queryLoop(queryChan <-chan *ConnectionInteraction, conn.forwardHeartbeatFrame() // avoid initial wait } } - var heartbeat, fetchAll, fragTest <-chan time.Time terminate := false for !terminate { if err != nil { conn.log("error:", err) break } - heartbeat = tickerChan(conn.heartbeat) - fetchAll = tickerChan(conn.fetchAll) - fragTest = tickerChan(conn.fragTest) + heartbeat := tickerChan(conn.heartbeat) + fetchAll := tickerChan(conn.fetchAll) + fragTest := tickerChan(conn.fragTest) select { case query, ok := <-queryChan: if !ok {