Java 类org.apache.http.client.fluent.Response 实例源码

项目：CarmenRest-VertX 文件：RestResponseTests.java

@Test
 public void testCustomStatus()
 {
  Choir testChoir = new Choir();

  Response result = TestUtility.postGetResponse(choirBase + "nameOfChoirBlocking", testChoir.toJson(false));

  HttpResponse response = null;

  try {
      response = result.returnResponse();
} catch (IOException e1) {
    e1.printStackTrace();
}

assertTrue(response.getStatusLine().getStatusCode() == 400);

assertTrue(response.getStatusLine().getReasonPhrase().equals("Choir Name is required!"));  
 }

项目：CarmenRest-VertX 文件：RestResponseTests.java

@Test
 public void testCustomHeaders()
 {
  Choir testChoir = new Choir();

  Response result = TestUtility.postGetResponse(choirBase + "nameOfChoirHeaders", testChoir.toJson(false));

  HttpResponse response = null;

  try {
      response = result.returnResponse();
} catch (IOException e1) {
    e1.printStackTrace();
}

// Normally would return plain text because the ResultType annotation is missing on the handling method
assertTrue(response.getHeaders("content-type")[0].getValue().equals("application/json; charset=utf-8"));  
 }

项目：kurento-testing 文件：OrionConnector.java

/**
 * Sends a request to Orion
 *
 * @param ctxElement
 *          The context element
 * @param path
 *          the path from the context broker that determines which "operation"will be executed
 * @param responseClazz
 *          The class expected for the response
 * @return The object representing the JSON answer from Orion
 * @throws OrionConnectorException
 *           if a communication exception happens, either when contacting the context broker at
 *           the given address, or obtaining the answer from it.
 */
private <E, T> T sendRequestToOrion(E ctxElement, String path, Class<T> responseClazz) {
  String jsonEntity = gson.toJson(ctxElement);
  log.debug("Send request to Orion: {}", jsonEntity);

  Request req = Request.Post(this.orionAddr.toString() + path)
      .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);
  }

  HttpResponse httpResponse = checkResponse(response);

  T ctxResp = getOrionObjFromResponse(httpResponse, responseClazz);
  log.debug("Sent to Orion. Obtained response: {}", httpResponse);

  return ctxResp;
}

项目：XPages-Fusion-Application 文件：ImageRecognition.java

public ArrayList<String[]> getVisualRecog(String imageUrl) throws JsonException, URISyntaxException, IOException {
    String apiKey = bluemixUtil.getApiKey();

    String getUrl = bluemixUtil.getBaseUrl().replace("https:", "http:") + CLASSIFY_API + "?url=" + imageUrl + "&api_key=" + apiKey + "&version=" + VERSION;
    Response response = rest.get(getUrl);

    //Convert the response into JSON data
    String content = EntityUtils.toString(response.returnResponse().getEntity());
    JsonJavaObject jsonData = rest.parse(content);

    //Retrieve the list of highest matching classifiers and associated confidences
    ArrayList<String[]> tags = getSuggestedTags(jsonData);
    if(tags != null && tags.size() > 0) {
        return tags;
    }
    return null;
}

项目：XPages-Fusion-Application 文件：RestUtil.java

/**
 * Send POST request with authorization header and additional headers
 * @param url - The url of the POST request
 * @param auth - String for authorization header
 * @param headers - Hashmap of headers to add to the request
 * @param postData - The body of the POST
 * @return the Response to the POST request
 */
public Response post(String url, String auth, HashMap<String, String> headers, JsonJavaObject postData) throws JsonException, IOException, URISyntaxException {
    URI normUri = new URI(url).normalize();
    Request postRequest = Request.Post(normUri);

    //Add all headers
    if(StringUtil.isNotEmpty(auth)) {
        postRequest.addHeader("Authorization", auth);
    }
    if(headers != null && headers.size() > 0){
        for (Map.Entry<String, String> entry : headers.entrySet()) {
            postRequest.addHeader(entry.getKey(), entry.getValue());
        }
    }

    String postDataString = JsonGenerator.toJson(JsonJavaFactory.instanceEx, postData);
    Response response = executor.execute(postRequest.bodyString(postDataString, ContentType.APPLICATION_JSON));
    return response;
}

项目：XPages-Fusion-Application 文件：RestUtil.java

public Response post(String url, String auth, JsonJavaObject postData, File fileUpload) throws JsonException, IOException, URISyntaxException {
    URI normUri = new URI(url).normalize();
    Request postRequest = Request.Post(normUri);

    //Add all headers
    if(StringUtil.isNotEmpty(auth)) {
        postRequest.addHeader("Authorization", auth);
    }

    MultipartEntityBuilder builder = MultipartEntityBuilder.create();
    builder.addBinaryBody("images_file", fileUpload, ContentType.APPLICATION_OCTET_STREAM, fileUpload.getName());

    if(postData != null) {
        String postDataString = JsonGenerator.toJson(JsonJavaFactory.instanceEx, postData);
        builder.addTextBody("classifier_ids", postDataString, ContentType.MULTIPART_FORM_DATA);
    }

    HttpEntity multipart = builder.build();
    postRequest.body(multipart);

    Response response = executor.execute(postRequest);
    return response;
}

项目：XPages-Fusion-Application 文件：RestUtil.java

/**
 * Send PUT request with authorization header
 * @param url - The url of the POST request
 * @param auth - String for authorization header
 * @param putData - The body of the PUT
 */
public Response put(String url, String auth, JsonJavaObject putData) throws URISyntaxException, IOException, JsonException {
    URI normUri = new URI(url).normalize();
    Request putRequest = Request.Put(normUri);

    //Add auth header
    if(StringUtil.isNotEmpty(auth)) {
        putRequest.addHeader("Authorization", auth);
    }

    //Add put data
    String putDataString = JsonGenerator.toJson(JsonJavaFactory.instanceEx, putData);
    if(putData != null) {
        putRequest = putRequest.bodyString(putDataString, ContentType.APPLICATION_JSON);
    }

    Response response = executor.execute(putRequest);
    return response;
}