RestTemplate restTemplate = new RestTemplate();
String fooResourceUrl
= "http://localhost:8080/spring-rest/foos";
ResponseEntity<String> response
= restTemplate.getForEntity(fooResourceUrl + "/1", String.class);
assertThat(response.getStatusCode(), equalTo(HttpStatus.OK));
public class GetForEntityDemo {
public static void main(String args[]) {
RestTemplate restTemplate = new RestTemplate();
String url = "http://localhost:8080/spring-rest/data/fetch/{name}/{village}";
Map<String, String> map = new HashMap<String, String>();
map.put("name", "Mahesh");
map.put("village", "Dhananjaypur");
ResponseEntity<Person> personEntity = restTemplate.getForEntity(url, Person.class, map);
System.out.println("Name:"+personEntity.getBody().getName());
System.out.println("Village:"+personEntity.getBody().getAddress().getVillage());
}
}
public List<Person> getAllPerson() {
ResponseEntity<Person[]> response = restTemplate.getForEntity(ROOT_URI, Person[].class);
return Arrays.asList(response.getBody());
}
ResponseEntity<User> responseEntity = restTemplate.getForEntity(uri, User.class); // (1)
HttpStatus statusCode = responseEntity.getStatusCode(); // (2)
HttpHeaders header = responseEntity.getHeaders(); // (3)
User user = responseEntity.getBody(); // (4)
public class UserClient {
public static void main(String[] args) {
RestTemplate restTemplate = new RestTemplate();
ResponseEntity<String> responseEntity = restTemplate.getForEntity(
"http://localhost:8080/users/40", String.class);
System.out.println("-- response --");
System.out.println("status: "+responseEntity.getStatusCodeValue());
System.out.println("headers: "+responseEntity.getHeaders().toSingleValueMap());
System.out.println("body: "+responseEntity.getBody());
}
}
public R getResourcesFromGet(final RestTemplate rt, final URI targetURI) {
ResponseEntity<R> resp = rt.getForEntity(targetURI, getTypeClass());
if (resp != null) {
if (LOG.isDebugEnabled()) {
LOG.debug("response is not null: " + resp.getStatusCode());
}
if (resp.getStatusCode() == HttpStatus.OK) {
if (LOG.isDebugEnabled()) {
LOG.debug("response is OK");
}
this.processHeaders(targetURI, resp.getHeaders());
return resp.getBody();
} else {
return null;
}
} else {
return null;
}
}
protected List<JsonRole> getResourcesFromGet(final RestTemplate rt, final URI targetURI)
throws HttpStatusCodeException, UpdaterHttpException {
ResponseEntity<JsonRoles> resp = rt.getForEntity(targetURI, JsonRoles.class);
if (resp != null) {
if (LOG.isDebugEnabled()) {
LOG.debug("response is not null: " + resp.getStatusCode());
}
if (resp.getStatusCode() == HttpStatus.OK) {
if (LOG.isDebugEnabled()) {
LOG.debug("response is OK");
}
return resp.getBody().getRoles();
} else {
throw new UpdaterHttpException(
"unable to collect roles - status code: " + resp.getStatusCode().toString());
}
} else {
throw new UpdaterHttpException("unable to collect roles - HTTP response was null");
}
}
protected List<JsonDomain> getResourcesFromGet(final RestTemplate rt, final URI targetURI)
throws HttpStatusCodeException, UpdaterHttpException {
ResponseEntity<JsonDomains> resp = rt.getForEntity(targetURI, JsonDomains.class);
if (resp != null) {
if (LOG.isDebugEnabled()) {
LOG.debug("response is not null: " + resp.getStatusCode());
}
if (resp.getStatusCode() == HttpStatus.OK) {
if (LOG.isDebugEnabled()) {
LOG.debug("response is OK");
}
return resp.getBody().getDomains();
} else {
throw new UpdaterHttpException(
"unable to collect domains - status code: " + resp.getStatusCode().toString());
}
} else {
throw new UpdaterHttpException("unable to collect domains - HTTP response was null");
}
}
public void testErrorsSerializedAsJsonApi() throws IOException {
RestTemplate testRestTemplate = new RestTemplate();
try {
testRestTemplate
.getForEntity("http://localhost:" + this.port + "/doesNotExist", String.class);
Assert.fail();
}
catch (HttpClientErrorException e) {
assertEquals(HttpStatus.NOT_FOUND, e.getStatusCode());
String body = e.getResponseBodyAsString();
ObjectMapper mapper = new ObjectMapper();
mapper.registerModule(JacksonModule.createJacksonModule());
Document document = mapper.readerFor(Document.class).readValue(body);
Assert.assertEquals(1, document.getErrors().size());
ErrorData errorData = document.getErrors().get(0);
Assert.assertEquals("404", errorData.getStatus());
Assert.assertEquals("Not Found", errorData.getTitle());
Assert.assertEquals("No message available", errorData.getDetail());
}
}
private T connect(final PathBuilder config) throws RestClientException {
final RestTemplate restTemplate = new RestTemplate(httpMessageConverters);
final SimpleClientHttpRequestFactory rf = (SimpleClientHttpRequestFactory) restTemplate.getRequestFactory();
rf.setReadTimeout(2000);
rf.setConnectTimeout(2000);
config.addParam("t", RestfulContext.getToken());
final ResponseEntity<T> re = restTemplate.getForEntity(config.buildEndpointURI(), dtoType);
return re.getBody();
}