summaryrefslogtreecommitdiffstats
path: root/dcae-analytics/dcae-analytics-web/src
diff options
context:
space:
mode:
authorTony Hansen <tony@att.com>2020-10-14 03:01:48 +0000
committerGerrit Code Review <gerrit@onap.org>2020-10-14 03:01:48 +0000
commit060c24eb0f5b3999661e107bba96f38e94f7d42f (patch)
treee109b5c377cc02990886d01e5b8326d81b5b4b7d /dcae-analytics/dcae-analytics-web/src
parenta7be50648450c1bddd70f1ec4a2dc4227a58bfa0 (diff)
parentc96f94f691a91265ba140bc49a54d533f7725d36 (diff)
Merge "Fix issue: requestID issue on TCAgen2 CL output" into guilin7.0.0-ONAPguilin
Diffstat (limited to 'dcae-analytics/dcae-analytics-web/src')
-rw-r--r--dcae-analytics/dcae-analytics-web/src/main/java/org/onap/dcae/analytics/web/dmaap/MrMessageSplitter.java4
1 files changed, 1 insertions, 3 deletions
diff --git a/dcae-analytics/dcae-analytics-web/src/main/java/org/onap/dcae/analytics/web/dmaap/MrMessageSplitter.java b/dcae-analytics/dcae-analytics-web/src/main/java/org/onap/dcae/analytics/web/dmaap/MrMessageSplitter.java
index 0396005..f8ab481 100644
--- a/dcae-analytics/dcae-analytics-web/src/main/java/org/onap/dcae/analytics/web/dmaap/MrMessageSplitter.java
+++ b/dcae-analytics/dcae-analytics-web/src/main/java/org/onap/dcae/analytics/web/dmaap/MrMessageSplitter.java
@@ -22,7 +22,6 @@ package org.onap.dcae.analytics.web.dmaap;
import static org.apache.commons.text.StringEscapeUtils.unescapeJava;
import static org.apache.commons.text.StringEscapeUtils.unescapeJson;
import static org.onap.dcae.analytics.model.AnalyticsHttpConstants.REQUEST_ID_HEADER_KEY;
-import static org.onap.dcae.analytics.model.AnalyticsModelConstants.ANALYTICS_REQUEST_ID_DELIMITER;
import java.io.IOException;
import java.util.Collections;
@@ -95,8 +94,7 @@ public class MrMessageSplitter extends AbstractMessageSplitter {
MessageBuilder
.withPayload(messagePartitions.get(0))
.copyHeaders(message.getHeaders())
- .setHeader(REQUEST_ID_HEADER_KEY,
- requestId + ANALYTICS_REQUEST_ID_DELIMITER + batchIndex)
+ .setHeader(REQUEST_ID_HEADER_KEY, requestId)
.build()
);