Package org.springframework.http.client

Examples of org.springframework.http.client.ClientHttpRequest


    @Test
    public void testCreateRequestFile() throws Exception {
        final String path = BASE_DIR + "requestData.json";
        final URI uri = getFile(path).toURI();
        final ClientHttpRequest request = resolvingFactory.createRequest(uri, HttpMethod.GET);

        final ClientHttpResponse response = request.execute();

        assertEquals(HttpStatus.OK, response.getStatusCode());

        String expected = Files.toString(getFile(path), Constants.DEFAULT_CHARSET);
        final String actual = new String(ByteStreams.toByteArray(response.getBody()), Constants.DEFAULT_CHARSET);
View Full Code Here


    @Test
    public void testCreateRequestRelativeFileToConfig() throws Exception {
        final String path = BASE_DIR + "requestData.json";
        final URI uri = new URI("file://requestData.json");
        final ClientHttpRequest request =
                resolvingFactory.createRequest(uri, HttpMethod.GET);

        final ClientHttpResponse response = request.execute();

        assertEquals(HttpStatus.OK, response.getStatusCode());

        String expected = Files.toString(getFile(path), Constants.DEFAULT_CHARSET);
        final String actual = new String(ByteStreams.toByteArray(response.getBody()), Constants.DEFAULT_CHARSET);
View Full Code Here

    }

    @Test(expected = IllegalFileAccessException.class)
    public void testCreateRequestIllegalFile() throws Exception {
        final URI uri = logbackXml.toURI();
        final ClientHttpRequest request = resolvingFactory.createRequest(uri, HttpMethod.GET);

        request.execute();
    }
View Full Code Here

   * @param method the HTTP method to exectute (GET, POST, etc.)
   * @return the created request
   * @throws IOException in case of I/O errors
   */
  protected ClientHttpRequest createRequest(URI url, HttpMethod method) throws IOException {
    ClientHttpRequest request = getRequestFactory().createRequest(url, method);
    if (logger.isDebugEnabled()) {
      logger.debug("Created " + method.name() + " request for \"" + url + "\"");
    }
    return request;
  }
View Full Code Here

    Assert.notNull(url, "'url' must not be null");
    Assert.notNull(method, "'method' must not be null");
    ClientHttpResponse response = null;
    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

    }

    @Override
    public void doWithRequest(final AsyncClientHttpRequest request) throws IOException {
      if (this.adaptee != null) {
        this.adaptee.doWithRequest(new ClientHttpRequest() {
          @Override
          public ClientHttpResponse execute() throws IOException {
            throw new UnsupportedOperationException("execute not supported");
          }
          @Override
View Full Code Here

    Assert.notNull(url, "'url' must not be null");
    Assert.notNull(method, "'method' must not be null");
    ClientHttpResponse response = null;
    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

        ClientHttpResponse resp = mock(ClientHttpResponse.class);
        when(resp.getStatusCode()).thenReturn(HttpStatus.ACCEPTED);
        when(resp.getHeaders()).thenReturn(new HttpHeaders());

        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        ClientHttpRequest client = mock(ClientHttpRequest.class);
        when(client.getHeaders()).thenReturn(headers);
        when(client.getBody()).thenReturn(buffer);
        when(client.execute()).thenReturn(resp);

        ClientHttpRequestFactory factory = mock(ClientHttpRequestFactory.class);
        when(factory.createRequest(any(URI.class), any(HttpMethod.class))).thenReturn(client);

        // add the new interceptor...
View Full Code Here

        ClientHttpResponse resp = mock(ClientHttpResponse.class);
        when(resp.getStatusCode()).thenReturn(HttpStatus.ACCEPTED);
        when(resp.getHeaders()).thenReturn(new HttpHeaders());

        ByteArrayOutputStream buffer = new ByteArrayOutputStream();
        ClientHttpRequest client = mock(ClientHttpRequest.class);
        when(client.getHeaders()).thenReturn(headers);
        when(client.getBody()).thenReturn(buffer);
        when(client.execute()).thenReturn(resp);

        ClientHttpRequestFactory factory = mock(ClientHttpRequestFactory.class);
        when(factory.createRequest(any(URI.class), any(HttpMethod.class))).thenReturn(client);

        // add the new interceptor...
View Full Code Here

    Assert.notNull(url, "'url' must not be null");
    Assert.notNull(method, "'method' must not be null");
    ClientHttpResponse response = null;
    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

TOP

Related Classes of org.springframework.http.client.ClientHttpRequest

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.