diff options
Diffstat (limited to 'datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java')
-rw-r--r-- | datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java b/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java index a3825f6..1cdacd8 100644 --- a/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java +++ b/datacollector/src/main/java/org/onap/rapp/datacollector/service/VesRetrievalService.java @@ -95,8 +95,8 @@ public class VesRetrievalService implements DmaapRestReader { } private void saveAllEvents(List<Event> events) { - persister.persistAll(events); saveUesOfVes(events); + persister.persistAll(removeTrafficModelFromEvents(events)); } private void saveUesOfVes(List<Event> events) { @@ -113,6 +113,13 @@ public class VesRetrievalService implements DmaapRestReader { .collect(Collectors.toSet())).orElse(Collections.emptySet()); } + private List<Event> removeTrafficModelFromEvents(List<Event> events) { + return events.stream().map(event -> { + event.getMeasurementFields().getAdditionalMeasurements() + .removeIf(additionalMeasurements -> UE_FIELD_NAME.equalsIgnoreCase(additionalMeasurements.getName())); + return event; + }).collect(Collectors.toList()); + } } |