Package org.apache.http.impl.client

Examples of org.apache.http.impl.client.DefaultHttpRequestRetryHandler

59
60
61
62
63
64
65
66
67
68
69
70
    @Test
    public void noRetryOnUnknownHost() throws Exception {
        HttpContext context = mock(HttpContext.class);
        HttpUriRequest request = mock(HttpUriRequest.class);

        DefaultHttpRequestRetryHandler retryHandler = new DefaultHttpRequestRetryHandler();

        when(request.isAborted()).thenReturn(Boolean.FALSE);
        when(context.getAttribute(ExecutionContext.HTTP_REQUEST)).thenReturn(request);

        Assert.assertFalse(retryHandler.retryRequest(new UnknownHostException(), 1, context));
    }
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
83
    @Test
    public void noRetryOnAbortedRequests() throws Exception{
        HttpContext context = mock(HttpContext.class);
        HttpUriRequest request = mock(HttpUriRequest.class);

        DefaultHttpRequestRetryHandler retryHandler = new DefaultHttpRequestRetryHandler();

        when(request.isAborted()).thenReturn(Boolean.TRUE);
        when(context.getAttribute(ExecutionContext.HTTP_REQUEST)).thenReturn(request);

        Assert.assertFalse(retryHandler.retryRequest(new IOException(),3,context));
    }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
97
    public void retryOnNonAbortedRequests() throws Exception{

        HttpContext context = mock(HttpContext.class);
        HttpUriRequest request = mock(HttpUriRequest.class);

        DefaultHttpRequestRetryHandler retryHandler = new DefaultHttpRequestRetryHandler();

        when(request.isAborted()).thenReturn(Boolean.FALSE);
        when(context.getAttribute(ExecutionContext.HTTP_REQUEST)).thenReturn(request);

        Assert.assertTrue(retryHandler.retryRequest(new IOException(),3,context));
    }
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
111
    public void noRetryOnConnectionTimeout() throws Exception{

        HttpContext context = mock(HttpContext.class);
        HttpUriRequest request = mock(HttpUriRequest.class);

        DefaultHttpRequestRetryHandler retryHandler = new DefaultHttpRequestRetryHandler();

        when(request.isAborted()).thenReturn(false);
        when(context.getAttribute(ExecutionContext.HTTP_REQUEST)).thenReturn(request);

        Assert.assertFalse(retryHandler.retryRequest(new ConnectTimeoutException(),3,context));
    }
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
   */
  public static final HttpClient getClient(int timeout) {
    HttpClientBuilder client = HttpClientBuilder.create();
    client.setConnectionManager(connectionManager);
    // dont retry
    client.setRetryHandler(new DefaultHttpRequestRetryHandler(0, false));
    // establish a connection within x seconds
    RequestConfig config = RequestConfig.custom().setSocketTimeout(timeout).build();
    client.setDefaultRequestConfig(config);
    // no redirects
    client.disableRedirectHandling();
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
        final ConnectionReuseStrategy reuseStrategy = keepAlive == 0
                ? new NoConnectionReuseStrategy()
                : new DefaultConnectionReuseStrategy();
        final HttpRequestRetryHandler retryHandler = configuration.getRetries() == 0
                ? NO_RETRIES
                : (httpRequestRetryHandler == null ? new DefaultHttpRequestRetryHandler(configuration.getRetries(),
                false) : httpRequestRetryHandler);

        final RequestConfig requestConfig
                = RequestConfig.custom().setCookieSpec(cookiePolicy)
                .setSocketTimeout(timeout)
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
            // Add as the first request interceptor
            client.addRequestInterceptor(new PreemptiveAuth(), 0);
        }
        boolean requestSentRetryEnabled = Boolean.parseBoolean(System.getProperty("requestSentRetryEnabled"));
        if(requestSentRetryEnabled){
            client.setHttpRequestRetryHandler(new DefaultHttpRequestRetryHandler(3,requestSentRetryEnabled));
        }
        // set the following user agent with each request
        String userAgent = "ArtifactoryBuildClient/" + CLIENT_VERSION;
        HttpProtocolParams.setUserAgent(client.getParams(), userAgent);
        return client;
View Full Code Here
183
184
185
186
187
188
189
190
191
192
193
      ConnRouteParams.setDefaultProxy(
          client.getParams(), new HttpHost(splits[0], Integer.parseInt(splits[1]), "http"));
    }

    // try resending the request once
    client.setHttpRequestRetryHandler(new DefaultHttpRequestRetryHandler(1, true));

    // Add hooks for gzip/deflate
    client.addRequestInterceptor(new HttpRequestInterceptor() {
      public void process(
          final org.apache.http.HttpRequest request,
View Full Code Here
186
187
188
189
190
191
192
        setSocketOperationTimeout(60000);
        setRequestTimeout(-1);
    }

    public void setRetryCount(int count) {
        httpClient.setHttpRequestRetryHandler(new DefaultHttpRequestRetryHandler(count, false));
    }
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
            default:
                throw new IllegalStateException("Method not defined!");
        }
       
        // Retry handler (no-retries):
        hcBuilder.setRetryHandler(new DefaultHttpRequestRetryHandler(0, false));
       
        // Url:
        final URL url = IDNUtil.getIDNizedURL(request.getUrl());
        final String urlHost = url.getHost();
        final int urlPort = url.getPort()==-1?url.getDefaultPort():url.getPort();
View Full Code Here
TOP

Related Classes of org.apache.http.impl.client.DefaultHttpRequestRetryHandler

  • co.paralleluniverse.fibers.dropwizard.FiberHttpClientBuilder
  • com.aceevo.ursus.client.UrsusHttpClientBuilder
  • com.addthis.basis.net.HttpUtil
  • com.common.platform.utils.HttpUtils
  • com.emc.atmos.api.jersey.JerseyApacheUtil
  • com.facebook.presto.jdbc.internal.airlift.http.client.ApacheHttpClient
  • com.github.mrcritical.ironcache.internal.http.ApacheHttpTransport
  • com.google.api.client.http.apache.ApacheHttpTransport
  • com.groupon.odo.bmp.http.BrowserMobHttpClient
  • com.ibm.sbt.opensocial.domino.internal.DominoHttpFetcher
    • 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.