Package com.ning.http.client

Examples of com.ning.http.client.Response

287
288
289
290
291
292
293
294
295
296
297
298
     * @return a list of any reserved bookings for the customer
     */
    public List<BookingDetailsDto> getReservedBookingsForCustomer(String securityToken, String currency) {
        try {
            String uri = appendQueryParams(BASE + "/customer/" + securityToken + "/reserved", new NVP("currency", currency));
            Response r = prepareGet(uri).execute().get();
            validateResponse(r);
            return json.readValue(r.getResponseBody("UTF-8"), new TypeReference<List<BookingDetailsDto>>(){});
        } catch (Exception e) {
            throw wrapException(e);
        }
    }
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
52
53
54
        logger.info("{}: running test:  testSpecialCharsMapping", getClass().getSimpleName());

        AsyncHttpClient c = new AsyncHttpClient();
        try {
            long t1 = System.currentTimeMillis();
            Response r = c.prepareGet(urlTarget).execute().get(10, TimeUnit.SECONDS);
            assertNotNull(r);
            assertEquals(r.getStatusCode(), 200);
            String resume = r.getResponseBody();
            assertEquals(resume, "");
            long current = System.currentTimeMillis() - t1;
            assertTrue(current > 5000 && current < 10000);
        } catch (Exception e) {
            logger.error("test failed", e);
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
49
50
51
        logger.info("{}: running test:  testSpecialCharsMapping", getClass().getSimpleName());

        AsyncHttpClient c = new AsyncHttpClient();
        try {
            long t1 = System.currentTimeMillis();
            Response r = c.prepareGet(urlTarget + "/a?a=a&b=b").execute().get(10, TimeUnit.SECONDS);
            assertNotNull(r);
            assertEquals(r.getStatusCode(), 200);
            assertEquals(r.getResponseBody(), "ab");
        } catch (Exception e) {
            logger.error("test failed", e);
            fail(e.getMessage());
        }
        c.close();
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
                    .setPassword(masterSecret)
                    .setUsePreemptiveAuth(true)
                    .setScheme(Realm.AuthScheme.BASIC)
                    .build();
            // currently, not really async...
            Response response =
                    asyncHttpClient.preparePost(url)
                            .addHeader("Accept", "application/json")
                            .addHeader("Content-type", "application/json")
                            .setRealm(realm)
                            .setBody(jsonPayloadObject)
                            .execute().get();

            int statusCode = response.getStatusCode();
            if (statusCode != 200) {
                logger.severe("Receiving status code: " + statusCode);
            }
        } catch (Exception e) {
            e.printStackTrace();
View Full Code Here
67
68
69
70
71
72
73
74
    public void close() throws IOException {
        asyncHttpClient.close();
    }

    public ClientResponse handle(final ClientRequest request, final HandlerContext context) throws Exception {
        Response response = processRequest(request, context);
        return processResponse(request, context, response);
    }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
        AsyncHttpClient asyncHttpClient = openConnection(cr);
        NonCloseableOutputStream ncos = new NonCloseableOutputStream();
        OutputStream os = adaptOutputStream(ncos, cr, context.getOutputStreamAdapters());

        Request request = setupHttpRequest(cr, ncos, os);
        Response response;
        final AtomicReference<Throwable> failureHolder = new AtomicReference<Throwable>();

        try {
            response = asyncHttpClient.executeRequest(request, new AsyncCompletionHandlerBase()
            {
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
90
91
92
     * {@inheritDoc}
     */
    /* @Override */
    public final T onCompleted() throws Exception {
        if (status != null) {
            Response response = status.provider().prepareResponse(status, headers, bodies);
            Document document = null;
            if (status.getStatusCode() == 207) {
                document = readXMLResponse(response.getResponseBodyAsStream());
            }
            return onCompleted(new WebDavResponse(status.provider().prepareResponse(status, headers, bodies), document));
        } else {
            throw new IllegalStateException("Status is null");
        }
View Full Code Here
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
                  }
                  bsonArray.add(request.scriptResult);               
                }
              } // end script mode
              else { // HTTP mode
                Response endpointResponse = request.responseFuture.get();
                request.asyncClient.close();
                request.asyncClient = null;
   
                String jsonStr = endpointResponse.getResponseBody();
                String url = endpointResponse.getUri().toURL().toString();
               
                Object bsonUnknownType = com.mongodb.util.JSON.parse(jsonStr);
                BasicDBObject bson = null;
                if (bsonUnknownType instanceof BasicDBObject) {
                  bson = (BasicDBObject) bsonUnknownType;
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
  private WebResponse simpleRequest(RequestBuilder requestBuilder) {
    requestBuilder = addHeadersToRequestBuilder(requestBuilder);

    try {
      Response r = httpClient.executeRequest(requestBuilder.build()).get();
      return new WebResponseImpl(injector, r);
    } catch (IOException e) {
      throw new TransportException(e);
    } catch (InterruptedException e) {
      throw new TransportException(e);
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
      //
      // Set request body
      //
      requestBuilder.setBody(outBuffer);
      Response r = httpClient.executeRequest(requestBuilder.build()).get();
      return new WebResponseImpl(injector, r);
    } catch (IOException e) {
      throw new TransportException(e);
    } catch (InterruptedException e) {
      throw new TransportException(e);
View Full Code Here
TOP

Related Classes of com.ning.http.client.Response

  • cc.twittertools.download.FetchStatusTest
  • cc.twittertools.download.VerifyJsonStatusBlockCrawl
  • co.cask.cdap.gateway.handlers.AppFabricHttpHandler
  • com.cloudhopper.mq.broker.RemoteBrokerMonitor
  • com.fasterxml.clustermate.client.ahc.AHCContentDeleter
  • com.fasterxml.clustermate.client.ahc.AHCContentPutter
  • com.fasterxml.clustermate.client.ahc.AHCEntryLister
  • com.google.sitebricks.client.AHCWebClient
  • com.hubspot.singularity.data.SandboxManager
  • com.hubspot.singularity.executor.task.SingularityExecutorArtifactFetcher$SingularityExecutorTaskArtifactFetcher
    • 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.