gistfile1.txt

    public final void handleTransportFailure(IOException e) throws InterruptedException {
        if (LOG.isTraceEnabled()) {
            LOG.trace(this + " handleTransportFailure: " + e);
        }
        synchronized (reconnectMutex) {
            Transport transport = connectedTransport.getAndSet(null);

            if (transport != null) {

                disposeTransport(transport);

                boolean reconnectOk = false;

                if (canReconnect()) {
                    reconnectOk = true;
                }
                LOG.warn("Transport (" + transport.getRemoteAddress() + ") failed, reason:  " + e
                        + (reconnectOk ? "," : ", not") + " attempting to automatically reconnect");

                initialized = false;
                failedConnectTransportURI = connectedTransportURI;
                connectedTransportURI = null;
                connected = false;
                connectedToPriority = false;

                if (reconnectOk) {
                    // notify before any reconnect attempt so ack state can be whacked
                    if (transportListener != null) {
                        transportListener.transportInterupted();
                    }

                    updated.remove(failedConnectTransportURI);
                    reconnectTask.wakeup();
                } else if (!isDisposed()) {
                    propagateFailureToExceptionListener(e);
                }
            }
        }
    }