reconnectFuture.cancel(true); protocolSession.close();
if (reconnectFuture != null) { reconnectFuture.cancel(true); } if (protocolSession != null) { protocolSession.close(); }
    public void close() {        reconnectFuture.cancel(true);        protocolSession.close();        nextSocketAddressIndex = 0;    }