Package org.apache.http.conn.params

Examples of org.apache.http.conn.params.ConnPerRouteBean

200
201
202
203
204
205
206
207
208
209
210
    public void testMaxConnTotal()
            throws InterruptedException, ConnectionPoolTimeoutException {

        HttpParams params = createDefaultParams();
        ConnManagerParams.setMaxConnectionsPerRoute(params, new ConnPerRouteBean(1));
        ConnManagerParams.setMaxTotalConnections(params, 2);

        ThreadSafeClientConnManager mgr = createTSCCM(params, null);

        HttpHost target1 = new HttpHost("www.test1.invalid", 80, "http");
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
262
263
        HttpRoute route3 = new HttpRoute(target3, null, false);
       
        HttpParams params = createDefaultParams();
        ConnManagerParams.setMaxTotalConnections(params, 100);
       
        ConnPerRouteBean connPerRoute = new ConnPerRouteBean(1);
        connPerRoute.setMaxForRoute(route2, 2);
        connPerRoute.setMaxForRoute(route3, 3);
       
        ConnManagerParams.setMaxConnectionsPerRoute(params, connPerRoute);

        ThreadSafeClientConnManager mgr = createTSCCM(params, null);
View Full Code Here
320
321
322
323
324
325
326
327
328
329
330

    public void testReleaseConnection() throws Exception {

        HttpParams params = createDefaultParams();
        ConnManagerParams.setMaxConnectionsPerRoute(params, new ConnPerRouteBean(1));
        ConnManagerParams.setMaxTotalConnections(params, 3);

        ThreadSafeClientConnManager mgr = createTSCCM(params, null);

        HttpHost target1 = new HttpHost("www.test1.invalid", 80, "http");
View Full Code Here
423
424
425
426
427
428
429
430
431
432
433
    public void testShutdown() throws Exception {
        // 3.x: TestHttpConnectionManager.testShutdown

        HttpParams params = createDefaultParams();
        ConnManagerParams.setMaxConnectionsPerRoute(params, new ConnPerRouteBean(1));
        ConnManagerParams.setMaxTotalConnections(params, 1);

        ThreadSafeClientConnManager mgr = createTSCCM(params, null);

        HttpHost target = new HttpHost("www.test.invalid", 80, "http");
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
        // parameters with connection limit 1
        HttpParams params = new BasicHttpParams();
        HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1);
        HttpProtocolParams.setUseExpectContinue(params, false);
        ConnManagerParams.setMaxConnectionsPerRoute(params, new ConnPerRouteBean(1));
        ConnManagerParams.setMaxTotalConnections(params, 1);

        SchemeRegistry schreg = new SchemeRegistry();
        SocketFactory sf = PlainSocketFactory.getSocketFactory();
        schreg.register(new Scheme("http", sf, 80));
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
        ClientConnectionOperator operator = new DefaultClientConnectionOperator(
                supportedSchemes);
       
        BasicHttpParams params = new BasicHttpParams();
        ConnPerRouteBean connPerRoute = new ConnPerRouteBean(3);
        ConnManagerParams.setMaxConnectionsPerRoute(params, connPerRoute);
       
        ConnPoolByRoute connPool = new ConnPoolByRoute(operator, params);
        try {
            // Allocate max possible entries
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
        ClientConnectionOperator operator = new DefaultClientConnectionOperator(
                supportedSchemes);
       
        BasicHttpParams params = new BasicHttpParams();
        ConnPerRouteBean connPerRoute = new ConnPerRouteBean(3);
        ConnManagerParams.setMaxConnectionsPerRoute(params, connPerRoute);
       
        ConnPoolByRoute connPool = new ConnPoolByRoute(operator, params);
        try {
            // Allocate max possible entries
View Full Code Here
790
791
792
793
794
795
796
797
798
799
800
            // and disabling this check improves performance.
            HttpConnectionParams.setStaleCheckingEnabled(params, false);
           
            // FUTURE - set this on a per-route (host) basis when we have per-host policies for
            // doing partner crawls. We could define a BixoConnPerRoute class that supports this.
            ConnPerRouteBean connPerRoute = new ConnPerRouteBean(_fetcherPolicy.getMaxConnectionsPerHost());
            ConnManagerParams.setMaxConnectionsPerRoute(params, connPerRoute);

            HttpProtocolParams.setVersion(params, _httpVersion);
            HttpProtocolParams.setUserAgent(params, _userAgent.getUserAgentString());
            HttpProtocolParams.setContentCharset(params, "UTF-8");
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
        schemeRegistry.register( new Scheme( "https", new EasySSLSocketFactory(), 443 ) );

        HttpParams params = new BasicHttpParams();
        // TODO put this values to a configuration way ???
        params.setParameter( ConnManagerPNames.MAX_TOTAL_CONNECTIONS, 30 );
        params.setParameter( ConnManagerPNames.MAX_CONNECTIONS_PER_ROUTE, new ConnPerRouteBean( 30 ) );
        HttpProtocolParams.setVersion( params, HttpVersion.HTTP_1_1 );

        ClientConnectionManager cm = new ThreadSafeClientConnManager( params, schemeRegistry );

        httpClient = new DefaultHttpClient( cm, params );
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        HttpHost target = new HttpHost("localhost", port);
       
        HttpParams params = defaultParams.copy();
        ConnManagerParams.setMaxTotalConnections(params, workerCount);
        ConnManagerParams.setMaxConnectionsPerRoute(params,
                new ConnPerRouteBean(workerCount));
        ConnManagerParams.setTimeout(params, 10L);
       
        ThreadSafeClientConnManager mgr = new ThreadSafeClientConnManager(
                params, supportedSchemes);       
       
View Full Code Here
TOP

Related Classes of org.apache.http.conn.params.ConnPerRouteBean

  • bixo.fetcher.SimpleHttpFetcher
  • biz.neustar.loggly.LogglyHandler
  • com.github.rnewson.couchdb.lucene.HttpClientFactory
  • com.google.api.client.http.apache.ApacheHttpTransport
  • groovyx.net.http.AsyncHTTPBuilder
  • org.apache.camel.component.http4.HttpComponent
  • org.apache.continuum.buildagent.webdav.client.WorkingCopyWebdavClient
  • org.apache.droids.examples.SimpleRuntime
  • org.apache.http.conn.TestConnectionAutoRelease
  • org.apache.http.conn.TestConnectionReuse
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.