Exit consumer goroutine after connection becomes staled