if (isDisconnected() && this.state != 5) {
            throw new TransportException("Transport is disconnected " + this.name);
        }
        try {
            final long timeout = !params.contains(RequestParam.NO_TIMEOUT) ? getResponseTimeout(request) : 0;

            final long firstKey = doSend(request, response, params, timeout);

            if (Thread.currentThread() == this.thread) {