public void connect()

in client/src/main/java/org/apache/asyncweb/client/AsyncHttpClient.java [60:85]

• 23 lines of code
• 7 McCabe index (conditional complexity)

    public void connect(URI url, AsyncHttpClientCallback callback) throws Exception {
        connector.setConnectTimeout(connectionTimeout);

        String scheme = url.getScheme();
        int port = url.getPort();
        
        if (scheme.toLowerCase().equals("http") && port == -1) {
            port = 80;
        } else if (scheme.toLowerCase().equals("https") && port == -1) {
        	port = 443;
        }
        connector.setHandler(new HttpIoHandler(callback));
        ConnectFuture future = connector.connect(new InetSocketAddress(url
                .getHost(), port));
        future.awaitUninterruptibly();
        if (!future.isConnected()) {
            throw new IOException("Cannot connect to " + url.toString());
        }
        session = future.getSession();
        // now add the good filters
        if (scheme.toLowerCase().equals("https")) {
            SslFilter filter = new SslFilter(createClientSSLContext());
            filter.setUseClientMode(true);
            session.getFilterChain().addBefore("protocolFilter", "SSL", filter);
        }
    }