Examples of org.springframework.http.HttpEntity

org.springframework.http.HttpEntity

le.com", entity); or

 HttpEntity<String> entity = template.getForEntity("http://example.com", String.class); String body = entity.getBody(); MediaType contentType = entity.getHeaders().getContentType();

Can also be used in Spring MVC, as a return value from a @Controller method:

 @RequestMapping("/handle") public HttpEntity<String> handle() { HttpHeaders responseHeaders = new HttpHeaders(); responseHeaders.set("MyResponseHeader", "MyValue"); return new HttpEntity<String>("Hello World", responseHeaders); }

@author Arjen Poutsma @since 3.0.2 @see org.springframework.web.client.RestTemplate @see #getBody() @see #getHeaders()

      super(responseType);
      if (requestBody instanceof HttpEntity) {
        this.requestEntity = (HttpEntity) requestBody;
      }
      else if (requestBody != null) {
        this.requestEntity = new HttpEntity(requestBody);
      }
      else {
        this.requestEntity = HttpEntity.EMPTY;
      }
    }

View Full Code Here


        logger.debug("REST client update.  id={}  url='{}'", request.getId(), url);


        Map<String, Long> vars = createPkVars(request.getId());


        response = client.getRestTemplate().exchange(url, HttpMethod.PUT, new HttpEntity(request), responseClazz, vars).getBody();


        return response;
    }

View Full Code Here


        switch (httpMethod) {
            case POST: {
                return client.getRestTemplate().postForObject(uri, request, responseClazz, urlVariables);
            } case PUT: {
                return client.getRestTemplate().exchange(uri, HttpMethod.PUT, new HttpEntity(request), responseClazz, urlVariables).getBody();
            } case DELETE: {
                return client.getRestTemplate().exchange(uri, HttpMethod.DELETE, new HttpEntity(request), responseClazz, urlVariables).getBody();


//                HttpEntityRequestCallback requestCallback = new HttpEntityRequestCallback(request, responseClazz);
//                HttpMessageConverterExtractor<ResponseResult> responseExtractor =
//                                new HttpMessageConverterExtractor<ResponseResult>(responseClazz, client.getRestTemplate().getMessageConverters());
//                return client.getRestTemplate().execute(uri, HttpMethod.DELETE, requestCallback, responseExtractor, urlVariables);

View Full Code Here

        private HttpEntityRequestCallback(Object requestBody, Class<?> responseType) {
            super(responseType);
            if (requestBody instanceof HttpEntity) {
                this.requestEntity = (HttpEntity) requestBody;
            } else if (requestBody != null) {
                this.requestEntity = new HttpEntity(requestBody);
            } else {
                this.requestEntity = HttpEntity.EMPTY;
            }
        }

View Full Code Here


  public static Map<String, String> getTunnelServiceInfo(CloudFoundryClient client, String serviceName) {
    String urlToUse = getTunnelUri(client) + "/services/" + serviceName;
    HttpHeaders requestHeaders = new HttpHeaders();
    requestHeaders.set("Auth-Token", getTunnelAuth(client));
    HttpEntity<?> requestEntity = new HttpEntity(requestHeaders);
    HttpEntity<String> response = restTemplate.exchange(urlToUse, HttpMethod.GET, requestEntity, String.class);
    String json = response.getBody().trim();
    Map<String, String> svcInfo = new HashMap<String, String>();
    try {
      svcInfo = convertJsonToMap(json);

View Full Code Here


  public static String getTunnelProtocolVersion(CloudFoundryClient client, String uri) {
    String uriToUse = uri + "/info";
    HttpHeaders requestHeaders = new HttpHeaders();
    requestHeaders.set("Auth-Token", getTunnelAuth(client));
    HttpEntity<?> requestEntity = new HttpEntity(requestHeaders);
    HttpEntity<String> response = restTemplate.exchange(uriToUse, HttpMethod.GET, requestEntity, String.class);
    return response.getBody().trim();
  }

View Full Code Here

    if (logger.isDebugEnabled()) {
      logger.debug("Deleting tunnel " + this.tunnelInfo.get("path"));
    }
    HttpHeaders requestHeaders = new HttpHeaders();
    requestHeaders.set("Auth-Token", auth);
    HttpEntity<?> requestEntity = new HttpEntity(requestHeaders);
    try {
      restOperations.exchange(url + this.tunnelInfo.get("path"), HttpMethod.DELETE, requestEntity, null);
    } catch (HttpClientErrorException e) {
      if (e.getStatusCode().value() == 404) {
        if (logger.isDebugEnabled()) {

View Full Code Here

    final byte[][] sent = new byte[1][1];
    when(restTemplate.exchange(isA(String.class), isA(HttpMethod.class), isA(HttpEntity.class), (Class)isNull()))
        .thenAnswer(new Answer<ResponseEntity<?>>() {
          public ResponseEntity<?> answer(InvocationOnMock invocation) throws Throwable {
            Object[] args = invocation.getArguments();
            HttpEntity arg3 = (HttpEntity) args[2];
            sent[0] = (byte[]) arg3.getBody();
            return response;
          }
        });
    httpTunnel.write(data);
    verify(restTemplate).exchange(isA(String.class), isA(HttpMethod.class), isA(HttpEntity.class), (Class)isNull());

View Full Code Here


  @SuppressWarnings({ "rawtypes", "unchecked" })
  public void changePassword(String oldPassword, String newPassword) {
    HttpHeaders headers = new HttpHeaders();
    headers.add(AUTHORIZATION_HEADER_KEY, token.getTokenType() + " " + token.getValue());
    HttpEntity info = new HttpEntity(headers);
    ResponseEntity<String> response = restTemplate.exchange(authorizationUrl + "/userinfo", HttpMethod.GET, info, String.class);
    Map<String, Object> responseMap = JsonUtil.convertJsonToMap(response.getBody());
    String userId = (String) responseMap.get("user_id");
    Map<String, Object> body = new HashMap<String, Object>();
    body.put("schemas", new String[] {"urn:scim:schemas:core:1.0"});

View Full Code Here

  @Test
  @SuppressWarnings({ "unchecked", "rawtypes" })
  public void exchangeGet() throws Exception {
    HttpHeaders requestHeaders = new HttpHeaders();
    requestHeaders.set("MyHeader", "MyValue");
    HttpEntity<?> requestEntity = new HttpEntity(requestHeaders);
    Future<ResponseEntity<String>> responseFuture =
        template.exchange(baseUrl + "/{method}", HttpMethod.GET, requestEntity, String.class, "get");
    ResponseEntity<String> response = responseFuture.get();
    assertEquals("Invalid content", helloWorld, response.getBody());
  }

View Full Code Here

0 1 2 3

TOP

Related Classes of org.springframework.http.HttpEntity

com.brightcove.zencoder.client.ZencoderClient

org.cloudfoundry.caldecott.client.HttpTunnel

org.cloudfoundry.caldecott.client.HttpTunnelTest

org.cloudfoundry.caldecott.client.TunnelHelper

org.cloudfoundry.client.lib.oauth2.OauthClient

org.springbyexample.contact.web.client.AbstractPersistenceClient

org.springbyexample.mvc.rest.client.factory.RestClientInvocationHandler

org.springbyexample.mvc.rest.client.factory.RestClientInvocationHandler$HttpEntityRequestCallback

org.springframework.http.converter.FormHttpMessageConverter

org.springframework.web.client.AsyncRestTemplateIntegrationTests

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.