Examples of org.apache.http.nio.conn.scheme.AsyncSchemeRegistry.register()

Class org.apache.http.nio.conn.scheme.AsyncSchemeRegistry

Examples of org.apache.http.nio.conn.scheme.AsyncSchemeRegistry.register()

org.apache.http.nio.conn.scheme.AsyncSchemeRegistry.register()
Registers a scheme. The scheme can later be retrieved by its name using {@link #getScheme(String) getScheme} or {@link #get get}. @param sch the scheme to register @return the scheme previously registered with that name, ornull if none was registered

        });
        // Start the client thread
        t.start();
        
        AsyncSchemeRegistry registry = new AsyncSchemeRegistry();
        registry.register(new AsyncScheme("http", 80, null));
        registry.register(new AsyncScheme("https", 443, null));


        connectionManager = new PoolingClientAsyncConnectionManager(ioReactor, registry, 
                                                                    connectionTTL, TimeUnit.MILLISECONDS) {
            @Override

View Full Code Here

        // Start the client thread
        t.start();
        
        AsyncSchemeRegistry registry = new AsyncSchemeRegistry();
        registry.register(new AsyncScheme("http", 80, null));
        registry.register(new AsyncScheme("https", 443, null));


        connectionManager = new PoolingClientAsyncConnectionManager(ioReactor, registry, 
                                                                    connectionTTL, TimeUnit.MILLISECONDS) {
            @Override
            protected ClientAsyncConnectionFactory createClientAsyncConnectionFactory() {

View Full Code Here

            if (tlsClientParameters != null && tlsClientParameters.hashCode() == lastTlsHash && sslState != null) {
                ctx.setAttribute(ClientContext.USER_TOKEN , sslState);
            }
            
            final AsyncSchemeRegistry reg = new AsyncSchemeRegistry();
            reg.register(new AsyncScheme("http", 80, null));
            if ("https".equals(url.getScheme())) {
                try {
                    // check tlsClientParameters from message header
                    TLSClientParameters tlsClientParameters = outMessage.get(TLSClientParameters.class);
                    if (tlsClientParameters == null) {

View Full Code Here

                    if (tlsClientParameters == null) {
                        tlsClientParameters = new TLSClientParameters();
                    }


                    final SSLContext sslcontext = getSSLContext(tlsClientParameters);
                    reg.register(new AsyncScheme("https", 443, new SSLLayeringStrategy(sslcontext) {
                        @Override
                        protected void initializeEngine(SSLEngine engine) {
                            initializeSSLEngine(sslcontext, engine);
                        }
                        @Override

View Full Code Here

    }


    public void initClient() throws Exception {
        this.ioreactor = new DefaultConnectingIOReactor();
        AsyncSchemeRegistry schemeRegistry = new AsyncSchemeRegistry();
        schemeRegistry.register(new AsyncScheme("http", 80, null));
        this.connMgr = new PoolingAsyncClientConnectionManager(this.ioreactor, schemeRegistry);
        this.httpclient = new DefaultHttpAsyncClient(this.connMgr);
        this.httpclient.getParams()
            .setIntParameter(CoreConnectionPNames.SO_TIMEOUT, 60000)
            .setIntParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, 60000)

View Full Code Here

@ThreadSafe
public final class AsyncSchemeRegistryFactory {


    public static AsyncSchemeRegistry createDefault() {
        AsyncSchemeRegistry registry = new AsyncSchemeRegistry();
        registry.register(
                new AsyncScheme("http", 80, null));
        registry.register(
                new AsyncScheme("https", 443, SSLLayeringStrategy.getDefaultStrategy()));
        return registry;
    }

View Full Code Here


    public static AsyncSchemeRegistry createDefault() {
        AsyncSchemeRegistry registry = new AsyncSchemeRegistry();
        registry.register(
                new AsyncScheme("http", 80, null));
        registry.register(
                new AsyncScheme("https", 443, SSLLayeringStrategy.getDefaultStrategy()));
        return registry;
    }


}

View Full Code Here

            if (tlsClientParameters != null && tlsClientParameters.hashCode() == lastTlsHash && sslState != null) {
                ctx.setAttribute(ClientContext.USER_TOKEN , sslState);
            }
            
            final AsyncSchemeRegistry reg = new AsyncSchemeRegistry();
            reg.register(new AsyncScheme("http", 80, null));
            if ("https".equals(url.getScheme())) {
                try {
                    final SSLContext sslcontext = getSSLContext();
                    reg.register(new AsyncScheme("https", 443, new SSLLayeringStrategy(sslcontext) {
                        @Override

View Full Code Here

            final AsyncSchemeRegistry reg = new AsyncSchemeRegistry();
            reg.register(new AsyncScheme("http", 80, null));
            if ("https".equals(url.getScheme())) {
                try {
                    final SSLContext sslcontext = getSSLContext();
                    reg.register(new AsyncScheme("https", 443, new SSLLayeringStrategy(sslcontext) {
                        @Override
                        protected void initializeEngine(SSLEngine engine) {
                            initializeSSLEngine(sslcontext, engine);
                        }
                        @Override

View Full Code Here

        });
        // Start the client thread
        t.start();
        
        AsyncSchemeRegistry registry = new AsyncSchemeRegistry();
        registry.register(new AsyncScheme("http", 80, null));
        registry.register(new AsyncScheme("https", 443, null));


        connectionManager = new PoolingClientAsyncConnectionManager(ioReactor, registry, 
                                                                    connectionTTL, TimeUnit.MILLISECONDS) {
            @Override

View Full Code Here

0 1 2 3

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.