Fix deadlock when next connection to be staled before previous staled connection is processed (refs #5, thanks to @jweir)
Exit consumer goroutine after connection becomes staled