diff options
| author |   rv871f <richard.vondadelszen@amdocs.com> | 2018-03-20 10:21:42 -0400 |
|---|---|---|
| committer | rv871f <richard.vondadelszen@amdocs.com> | 2018-03-20 11:03:34 -0400 |
| commit | bf99eb77b31a4cfbc590762cc6ba669820c21439 (patch) | |
| tree | 6251d665e64a09eb98e79540967dff832f4226b4 /src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java | |
| parent | 1aae9de4d596a1108818c2d035225a3ba2737501 (diff) | |
Process VNF event from spike
Issue-ID: AAI-899
Change-Id: I2d056734e6af0fe0b4efe92681971e2b74153a0e
Signed-off-by: rv871f <richard.vondadelszen@amdocs.com>
Diffstat (limited to 'src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java')
| -rw-r--r-- | src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java b/src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java index fe1df3b..42861b4 100644 --- a/src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java +++ b/src/main/java/org/onap/aai/datarouter/util/SearchServiceAgent.java @@ -127,6 +127,14 @@ public class SearchServiceAgent { createIndex(index, schemaLocation);
}
+ public void createSearchIndex(String index, String schemaLocation, String endUrl) {
+
+ // Create a mapping of the index name to schema location
+ indexSchemaMapping.put(index, schemaLocation);
+
+ // Now, create the index.
+ createIndex(index, schemaLocation, endUrl);
+ }
/**
* This method performs the actual work of creating a search index.
@@ -160,6 +168,30 @@ public class SearchServiceAgent { }
}
+ private void createIndex(String index, String schemaLocation, String endUrl) {
+
+ logger.debug("Creating search index, index name: = " + index + ", schemaLocation = " + schemaLocation);
+
+ MultivaluedMap<String, String> headers = new MultivaluedMapImpl();
+ headers.put("Accept", Arrays.asList("application/json"));
+ headers.put(Headers.FROM_APP_ID, Arrays.asList("DL"));
+ headers.put(Headers.TRANSACTION_ID, Arrays.asList(UUID.randomUUID().toString()));
+
+ String url = concatSubUri(searchUrl, endUrl, index);
+ try {
+
+ OperationResult result = searchClient.put(url, loadFileData(schemaLocation), headers,
+ MediaType.APPLICATION_JSON_TYPE, null);
+ if (!HttpUtil.isHttpResponseClassSuccess(result.getResultCode())) {
+ logger.error(DataRouterMsgs.FAIL_TO_CREATE_SEARCH_INDEX, index, result.getFailureCause());
+ } else {
+ logger.info(DataRouterMsgs.SEARCH_INDEX_CREATE_SUCCESS, index);
+ }
+
+ } catch (Exception e) {
+ logger.error(DataRouterMsgs.FAIL_TO_CREATE_SEARCH_INDEX, index, e.getLocalizedMessage());
+ }
+ }
/**
* Retrieves a document from the search service.
|