Examples of org.springframework.http.client.ClientHttpRequest.execute()

Class org.springframework.http.client.ClientHttpRequest

Examples of org.springframework.http.client.ClientHttpRequest.execute()

org.springframework.http.client.ClientHttpRequest.execute()
Execute this request, resulting in a {@link ClientHttpResponse} that can be read. @return the response result of the execution @throws IOException in case of I/O errors

    public void delete(final Long taskId) {
        ClientHttpResponse response = null;
        try {
            ClientHttpRequest request = getRestTemplate().getRequestFactory().createRequest(
                    URI.create(baseUrl + "task/delete/" + taskId), HttpMethod.GET);
            response = request.execute();
        } catch (IOException e) {
            throw new WebServiceException("Cannot send request to delete task " + taskId, e);
        } finally {
            if (response != null) {
                response.close();

View Full Code Here

      
    try {
        ClientHttpRequest request = getRestTemplate().getRequestFactory().createRequest(uri, HttpMethod.PUT);
        request.getBody().write(file);
        
        ClientHttpResponse response = request.execute();
        ResponseErrorHandler errorHandler = new DefaultResponseErrorHandler();
        if (errorHandler.hasError(response)) {
          errorHandler.handleError(response);
          return null;
        }

View Full Code Here

    try {
      ClientHttpRequest request = createRequest(url, method);
      if (requestCallback != null) {
        requestCallback.doWithRequest(request);
      }
      response = request.execute();
      if (!getErrorHandler().hasError(response)) {
        logResponseStatus(method, url, response);
      }
      else {
        handleResponseError(method, url, response);

View Full Code Here

    try {
      ClientHttpRequest request = createRequest(url, method);
      if (requestCallback != null) {
        requestCallback.doWithRequest(request);
      }
      response = request.execute();
      if (!getErrorHandler().hasError(response)) {
        logResponseStatus(method, url, response);
      }
      else {
        handleResponseError(method, url, response);

View Full Code Here

        ClientHttpRequest request =
                new TestClientHttpRequest(HttpMethod.GET,
                        new URI("http://somewhere:7365/testExecutionCollected"),
                        createIdentityHttpHeaders(Arrays.asList("Req-Header1", "Req-Header2")),
                        createMockClientHttpResponse(HttpStatus.OK, createIdentityHttpHeaders(Arrays.asList("Rsp-Header1", "Rsp-Header2"))));
        ClientHttpResponse response = request.execute();
        Operation op = assertExecuteRequest(request);
        assertRequestDetails(op, request);
        assertResponseDetails(op, response);


        TraceError err = assertTraceError(op, response);

View Full Code Here

        ClientHttpRequest request =
                new TestClientHttpRequest(HttpMethod.GET,
                        new URI("http://somewhere:7365/testExecutionCollected"),
                        createIdentityHttpHeaders(Arrays.asList("Req-Header1", "req-value1", "Req-Header2", "req-value2")),
                        createMockClientHttpResponse(HttpStatus.GATEWAY_TIMEOUT, createIdentityHttpHeaders(Arrays.asList("Rsp-Header1", "Rsp-Header2"))));
        ClientHttpResponse response = request.execute();
        Operation op = assertExecuteRequest(request);
        TraceError err = assertTraceError(op, response);
        assertNotNull("No error detected", err);
    }

View Full Code Here

        ClientHttpRequest request =
                new TestClientHttpRequest(HttpMethod.GET,
                        new URI("http://somewhere:7365/" + testName),
                        reqHdrs,
                        createMockClientHttpResponse(HttpStatus.OK, rspHdrs));
        ClientHttpResponse response = request.execute();
        assertNotNull("No response", response);


        ObscuredValueSetMarker obsMarker = (ObscuredValueSetMarker) obfuscator.getSensitiveValueMarker();
        for (String name : hdrs) {
            assertTrue("Value not obscured for " + name, obsMarker.remove(name));

View Full Code Here

        factory.setReadTimeout(15 * 1000);


        URI uri = new URI("http://localhost:" + TEST_PORT + "/testConnectionFactory");
        HttpMethod method = HttpMethod.GET;
        ClientHttpRequest request = factory.createRequest(uri, method);
        ClientHttpResponse response = request.execute();
        assertEquals("Mismatched response code", HttpStatus.OK.value(), response.getRawStatusCode());


        BufferedReader rdr = new BufferedReader(new InputStreamReader(response.getBody()));
        try {
            for (String line = rdr.readLine(); line != null; line = rdr.readLine()) {

View Full Code Here

public class PrintApiTest extends AbstractApiTest {


    @Test
    public void testListApps() throws Exception {
        ClientHttpRequest request = getPrintRequest(MapPrinterServlet.LIST_APPS_URL, HttpMethod.GET);
        response = request.execute();
        assertEquals(HttpStatus.OK, response.getStatusCode());
        assertEquals(getJsonMediaType(), response.getHeaders().getContentType());
        final JSONArray appIdsJson = new JSONArray(getBodyAsText(response));
        assertTrue(appIdsJson.length() > 0);
    }

View Full Code Here

    }


    @Test
    public void testListAppsJsonp() throws Exception {
        ClientHttpRequest request = getPrintRequest(MapPrinterServlet.LIST_APPS_URL + "?jsonp=listApps", HttpMethod.GET);
        response = request.execute();
        assertEquals(HttpStatus.OK, response.getStatusCode());
        assertEquals(getJavaScriptMediaType(), response.getHeaders().getContentType());


        String responseAsText = getBodyAsText(response);
        assertTrue(responseAsText.startsWith("listApps("));

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.