X-Git-Url: https://gerrit.onap.org/r/gitweb?p=aai%2Fdata-router.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fdatarouter%2Fpolicy%2FSpikeEntitySearchProcessor.java;h=98d93d12aad5be64180ef6a7ce0a9dd7ce40cce1;hp=8b43b1b700ed992f7cbdf51f11ef3503f5ec21cc;hb=06576aee86306e15f01796b50f323939a6d1b531;hpb=39a4289baae38b7ad84f2c3b1e291e5bd81a9ccf diff --git a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntitySearchProcessor.java b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntitySearchProcessor.java index 8b43b1b..98d93d1 100644 --- a/src/main/java/org/onap/aai/datarouter/policy/SpikeEntitySearchProcessor.java +++ b/src/main/java/org/onap/aai/datarouter/policy/SpikeEntitySearchProcessor.java @@ -115,13 +115,13 @@ public class SpikeEntitySearchProcessor extends AbstractSpikeEntityEventProcesso * "content", sourceObject); * * if (!sourceObject.isEmpty()) { JsonNode node = sourceObject.get(0); final String sourceCer = - * NodeUtils.extractFieldValueFromObject(node, "crossEntityReferenceValues"); String newCer = + * NodeUtils.extractFieldValueFromObject(node, "crossReferenceEntityValues"); String newCer = * spikeEventEntity.getCrossReferenceEntityValues(); boolean hasNewCer = true; if (sourceCer != * null && sourceCer.length() > 0) { // already has CER if (!sourceCer.contains(newCer)) {// don't * re-add newCer = sourceCer + ";" + newCer; } else { hasNewCer = false; } } * * if (hasNewCer) { // Do the PUT with new CER ((ObjectNode) - * node).put("crossEntityReferenceValues", newCer); jsonPayload = + * node).put("crossReferenceEntityValues", newCer); jsonPayload = * NodeUtils.convertObjectToJson(node, false); searchAgent.putDocument(entitySearchIndex, * entityId, jsonPayload, headers); } } } else { *