diff options
Diffstat (limited to 'sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregation/sync')
-rw-r--r-- | sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregation/sync/AggregationSynchronizer.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregation/sync/AggregationSynchronizer.java b/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregation/sync/AggregationSynchronizer.java index dc6bdc0..70aaa93 100644 --- a/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregation/sync/AggregationSynchronizer.java +++ b/sparkybe-onap-service/src/main/java/org/onap/aai/sparky/aggregation/sync/AggregationSynchronizer.java @@ -278,7 +278,7 @@ public class AggregationSynchronizer extends AbstractEntitySynchronizer try { versionNumber = NodeUtils.extractFieldValueFromObject( NodeUtils.convertJsonStrToJsonNode(esGetTxn.getOperationResult().getResult()), - "_version"); + "etag"); } catch (IOException exc) { String message = "Error extracting version number from response, aborting aggregation entity sync of " @@ -303,7 +303,7 @@ public class AggregationSynchronizer extends AbstractEntitySynchronizer ArrayList<JsonNode> sourceObject = new ArrayList<JsonNode>(); NodeUtils.extractObjectsByKey( NodeUtils.convertJsonStrToJsonNode(esGetTxn.getOperationResult().getResult()), - "_source", sourceObject); + "content", sourceObject); if (!sourceObject.isEmpty()) { String responseSource = NodeUtils.convertObjectToJson(sourceObject.get(0), false); @@ -328,7 +328,7 @@ public class AggregationSynchronizer extends AbstractEntitySynchronizer String requestPayload = searchServiceAdapter.buildBulkImportOperationRequest(schemaConfig.getIndexName(), - ae.getId(),jsonPayload); + versionNumber, ae.getId(),jsonPayload); NetworkTransaction transactionTracker = new NetworkTransaction(); transactionTracker.setEntityType(esGetTxn.getEntityType()); |