X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fsa%2Fsearchdbabstraction%2Felasticsearch%2Fdao%2FElasticSearchHttpController.java;h=98a254c836af4bf67570a0d878342899465c1592;hb=82658daad05f982a8358581623f44a1554238a48;hp=90adbd70caba4ac52e7f658bc42b5e7152a27b89;hpb=fe84ae3b8d01ac2634d389f6b9d579319ea39f7a;p=aai%2Fsearch-data-service.git diff --git a/src/main/java/org/onap/aai/sa/searchdbabstraction/elasticsearch/dao/ElasticSearchHttpController.java b/src/main/java/org/onap/aai/sa/searchdbabstraction/elasticsearch/dao/ElasticSearchHttpController.java index 90adbd7..98a254c 100644 --- a/src/main/java/org/onap/aai/sa/searchdbabstraction/elasticsearch/dao/ElasticSearchHttpController.java +++ b/src/main/java/org/onap/aai/sa/searchdbabstraction/elasticsearch/dao/ElasticSearchHttpController.java @@ -370,7 +370,8 @@ public class ElasticSearchHttpController implements DocumentStoreInterface { try { attachContent(conn, ElasticSearchPayloadTranslator.translateESPayload(sb.toString())); } catch(IOException e) { - throw new DocumentStoreOperationException("Error in translating Index payload to make it ES compliant.", e); + logger.error(SearchDbMsgs.INDEX_CREATE_FAILURE, e); + throw new DocumentStoreOperationException(e.getMessage(), e); } logger.debug("\ncreateTable(), Sending 'PUT' request to URL : " + conn.getURL()); @@ -422,7 +423,8 @@ public class ElasticSearchHttpController implements DocumentStoreInterface { try { attachContent(conn, ElasticSearchPayloadTranslator.translateESPayload(settingsAndMappings)); } catch(IOException e) { - throw new DocumentStoreOperationException("Error in translating DynamicIndex payload to make it ES compliant.", e); + logger.error(SearchDbMsgs.INDEX_CREATE_FAILURE, e); + throw new DocumentStoreOperationException(e.getMessage()); } handleResponse(conn, result); @@ -571,12 +573,7 @@ public class ElasticSearchHttpController implements DocumentStoreInterface { // conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); conn.setRequestProperty("Content-Type", "application/json"); conn.setRequestProperty("Connection", "Close"); - - try { - attachContent(conn, ElasticSearchPayloadTranslator.translateESPayload(doc.getContentInJson())); - } catch(IOException e) { - throw new DocumentStoreOperationException("Error in translating Document payload to make it ES compliant.", e); - } + attachContent(conn, doc.getContentInJson()); } private DocumentOperationResult checkDocumentExistence(String indexName,