diff options
| author |   Kai <lukai@chinamobile.com> | 2020-10-12 12:46:07 +0800 |
|---|---|---|
| committer |   Vijay Venkatesh Kumar <vv770d@att.com> | 2020-10-13 12:22:18 +0000 |
| commit | c96f94f691a91265ba140bc49a54d533f7725d36 (patch) | |
| tree | 8ea4923270ac6f46140886a85f350049f05996ff | |
| parent | 85abdfd0c4b791eb5a149050bfd347ace53425a1 (diff) | |
Fix issue: requestID issue on TCAgen2 CL output
Issue-ID: DCAEGEN2-2469
Signed-off-by: Kai Lu <lukai@chinamobile.com>
Change-Id: I259a97242352fbe32d0711565008efe9256d47d9
(cherry picked from commit afa65f691d99aae98a18223ce1e670aba0f4cabd)
| -rw-r--r-- | dcae-analytics/dcae-analytics-web/src/main/java/org/onap/dcae/analytics/web/dmaap/MrMessageSplitter.java | 4 |
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() ); |