|
@@ -18,8 +18,13 @@ public class TrackingService {
|
|
|
private RestTemplate restTemplate = new RestTemplate();
|
|
|
|
|
|
public void save(TrackingEntity entity) {
|
|
|
- String url = esHost.concat("/tracking/log?pretty&pretty");
|
|
|
+ String url = esHost.concat("/").concat(entity.getType().toLowerCase()).concat("/log?pretty&pretty");
|
|
|
log.info("es host:{}", url);
|
|
|
- restTemplate.postForEntity(url, entity, String.class);
|
|
|
+ try{
|
|
|
+ restTemplate.postForEntity(url, entity.getPayload(), String.class);
|
|
|
+ }catch (Exception e){
|
|
|
+ e.printStackTrace();
|
|
|
+ throw new RuntimeException(e.getMessage());
|
|
|
+ }
|
|
|
}
|
|
|
}
|