diff options
Diffstat (limited to 'dcae-analytics/dcae-analytics-tca-web')
-rw-r--r-- | dcae-analytics/dcae-analytics-tca-web/pom.xml | 2 | ||||
-rw-r--r-- | dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java | 4 |
2 files changed, 2 insertions, 4 deletions
diff --git a/dcae-analytics/dcae-analytics-tca-web/pom.xml b/dcae-analytics/dcae-analytics-tca-web/pom.xml index 57f9bdf..1d9a89a 100644 --- a/dcae-analytics/dcae-analytics-tca-web/pom.xml +++ b/dcae-analytics/dcae-analytics-tca-web/pom.xml @@ -29,7 +29,7 @@ <parent> <groupId>org.onap.dcaegen2.analytics.tca-gen2</groupId> <artifactId>dcae-analytics</artifactId> - <version>1.2.0-SNAPSHOT</version> + <version>1.2.1-SNAPSHOT</version> </parent> <artifactId>dcae-analytics-tca-web</artifactId> diff --git a/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java b/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java index e05026c..7f6891d 100644 --- a/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java +++ b/dcae-analytics/dcae-analytics-tca-web/src/main/java/org/onap/dcae/analytics/tca/web/service/TcaProcessingServiceImpl.java @@ -27,7 +27,6 @@ import java.util.List; import java.util.stream.Collectors; import java.util.stream.IntStream; -import org.onap.dcae.analytics.model.AnalyticsModelConstants; import org.onap.dcae.analytics.tca.core.service.GenericTcaExecutionContext; import org.onap.dcae.analytics.tca.core.service.GenericTcaProcessingContext; import org.onap.dcae.analytics.tca.core.service.GenericTcaResultContext; @@ -69,8 +68,7 @@ public class TcaProcessingServiceImpl implements TcaProcessingService { return IntStream.range(0, cefMessages.size()) // generate initial Processing contexts .mapToObj(cefMessageIndex -> GenericTcaExecutionContext.builder() - .requestId(executionRequestId + - AnalyticsModelConstants.ANALYTICS_REQUEST_ID_DELIMITER + cefMessageIndex) + .requestId(executionRequestId) .transactionId(executionTransactionId) .messageIndex(cefMessageIndex) .cefMessage(cefMessages.get(cefMessageIndex)) |