Examples of execute()

Examples of org.apache.http.client.fluent.Request.execute()

248
249
250
251
252
253
254
255
256
257
258
        .addHeader("Accept", APPLICATION_JSON.getMimeType())
        .bodyString(jsonEntity, APPLICATION_JSON).connectTimeout(5000)
        .socketTimeout(5000);
    Response response;
    try {
      response = req.execute();
    } catch (IOException e) {
      throw new OrionConnectorException("Could not execute HTTP request",
          e);
    }
View Full Code Here

Examples of org.apache.http.impl.client.CloseableHttpClient.execute()

105
106
107
108
109
110
111
112
113
114
115
        }

        CloseableHttpClient http = HttpClients.createDefault();
        CloseableHttpResponse response = null;
        try {
            response = http.execute(get);

            if (response.getStatusLine().getStatusCode() != 200) {
                LOG.error("Expected version check HTTP status code [200] but got [{}]", response.getStatusLine().getStatusCode());
                return;
            }
View Full Code Here

Examples of org.apache.http.impl.client.ContentEncodingHttpClient.execute()

82
83
84
85
86
87
88
89
90
91
92
        ContentEncodingHttpClient client = new ContentEncodingHttpClient();
        try {
            message = "Hi";
            HttpGet get = new HttpGet(DefaultServer.getDefaultServerURL() + "/path");
            get.setHeader(Headers.ACCEPT_ENCODING_STRING, "deflate");
            HttpResponse result = client.execute(get);
            Assert.assertEquals(StatusCodes.OK, result.getStatusLine().getStatusCode());
            Header[] header = result.getHeaders(Headers.CONTENT_ENCODING_STRING);
            Assert.assertEquals(0, header.length);
            final String body = HttpClientUtils.readResponse(result);
            Assert.assertEquals("Hi", body);
View Full Code Here

Examples of org.apache.http.impl.client.DefaultHttpClient.execute()

443
444
445
446
447
448
449
450
451
452
453
    HttpParams params = new BasicHttpParams();
    params.setParameter("http.default-headers", headers);

    HttpClient httpclient = new DefaultHttpClient(params);
    HttpDelete httpdelete = new HttpDelete("http://localhost:" + PORT + "/delete");
    HttpResponse response = httpclient.execute(httpdelete);

    assertNotNull(response);
    assertEquals(200, response.getStatusLine().getStatusCode());
    assertEquals(new ProtocolVersion("HTTP", 1, 1), response.getStatusLine().getProtocolVersion());
    assertEquals("OK", response.getStatusLine().getReasonPhrase());
View Full Code Here

Examples of org.apache.http.impl.client.FutureRequestExecutionService.execute()

63
64
65
66
67
68
69
70
71
72
73
                }
            };

            // Simple request ...
            HttpGet request1 = new HttpGet("http://google.com");
            HttpRequestFutureTask<Boolean> futureTask1 = requestExecService.execute(request1,
                    HttpClientContext.create(), handler);
            Boolean wasItOk1 = futureTask1.get();
            System.out.println("It was ok? "  + wasItOk1);

            // Cancel a request
View Full Code Here

Examples of org.apache.http.impl.client.SystemDefaultHttpClient.execute()

206
207
208
209
210
211
212
213
214
215
216
            ((HttpEntityEnclosingRequestBase)httpRequest).setEntity(entity) ;
        }
        TypedInputStream ts = null ;
        // httpclient.getParams().setXXX
        try {
            HttpResponse response = httpclient.execute(httpRequest) ;

            int responseCode = response.getStatusLine().getStatusCode() ;
            String responseMessage = response.getStatusLine().getReasonPhrase() ;
           
            if ( HttpSC.isRedirection(responseCode) )
View Full Code Here

Examples of org.apache.http.impl.client.cache.CachingHttpClient.execute()

86
87
88
89
90
91
92
93
94
95
96
                EasyMock.same(context))).andReturn(response);
        EasyMock.replay(client);
       
        CachingHttpClient t = new CachingHttpClient(client, resourceFactory, httpCacheStorage, cacheConfig);

        HttpResponse response1 = t.execute(get, context);
        Assert.assertEquals(200, response1.getStatusLine().getStatusCode());
        EntityUtils.consume(response1.getEntity());
       
        EasyMock.verify(client);
       
View Full Code Here

Examples of org.apache.http.impl.execchain.ClientExecChain.execute()

103
104
105
106
107
108
109
110
111
112
113
        response.setHeader("Content-Length", "128");
        response.setHeader("ETag", "\"etag\"");
        response.setHeader("Cache-Control", "public, max-age=3600");
        response.setHeader("Last-Modified", DateUtils.formatDate(tenSecondsAgo));

        EasyMock.expect(backend.execute(
                EasyMock.eq(route),
                EasyMock.isA(HttpRequestWrapper.class),
                EasyMock.same(context),
                EasyMock.<HttpExecutionAware>isNull())).andReturn(Proxies.enhanceResponse(response));
        EasyMock.replay(backend);
View Full Code Here

Examples of org.apache.http.impl.nio.client.CloseableHttpAsyncClient.execute()

165
166
167
168
169
170
171
172
173
174
175
                HttpHost target = URIUtils.extractHost(get.getURI());
                BasicAsyncRequestProducer basicAsyncRequestProducer = new BasicAsyncRequestProducer(target, get);
                httpClient.start();
                try {
                    log.debug("sending request");
                    Future<HttpResponse> futureResponse = httpClient.execute(
                            basicAsyncRequestProducer,
                            new SSEResponseConsumer(requestHandler), new FutureCallback<HttpResponse>() {
                                public void completed(HttpResponse httpResponse) {
                                    log.debug("response received {}", httpResponse);
                                }
View Full Code Here

Examples of org.apache.http.impl.nio.client.DefaultHttpAsyncClient.execute()

515
516
517
518
519
520
521
522
523
524
525
            if (credProvider != null && credProvider.getCredentials(AuthScope.ANY) != null) {
                ctx.setAttribute(ClientContext.USER_TOKEN,
                                 credProvider.getCredentials(AuthScope.ANY).getUserPrincipal());
            }
           
            c.execute(new CXFHttpAsyncRequestProducer(entity, outbuf),
                      new CXFHttpAsyncResponseConsumer(this, inbuf, responseCallback),
                      ctx,
                      callback);
        }
       
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.