aboutsummaryrefslogtreecommitdiffstats
path: root/datafile-app-server
diff options
context:
space:
mode:
authorHenrik Andersson <henrik.b.andersson@est.tech>2019-05-07 11:27:11 +0000
committerGerrit Code Review <gerrit@onap.org>2019-05-07 11:27:11 +0000
commitf43d5f564435fa79d13d6876f5cf438b51a95ff3 (patch)
tree4e30c33dc8f89958cfb1a6237933596b69dbfd82 /datafile-app-server
parent8e3c45f80631938013e67863a167df00c57cd4f0 (diff)
parent9e9f0077a6bc1c5bce89caec957b7577d1df0c06 (diff)
Merge "Bugfix, trace context"
Diffstat (limited to 'datafile-app-server')
-rw-r--r--datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java6
1 files changed, 2 insertions, 4 deletions
diff --git a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java
index 950fbae9..4028ac3f 100644
--- a/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java
+++ b/datafile-app-server/src/main/java/org/onap/dcaegen2/collectors/datafile/tasks/DataRouterPublisher.java
@@ -83,9 +83,7 @@ public class DataRouterPublisher {
public Mono<FilePublishInformation> publishFile(FilePublishInformation publishInfo, long numRetries,
Duration firstBackoff) {
MDC.setContextMap(publishInfo.getContext());
- logger.trace("publishFile called with arg {}", publishInfo);
dmaapProducerReactiveHttpClient = resolveClient();
-
return Mono.just(publishInfo) //
.cache() //
.flatMap(this::publishFile) //
@@ -93,8 +91,8 @@ public class DataRouterPublisher {
.retryBackoff(numRetries, firstBackoff);
}
- private Mono<HttpStatus> publishFile(FilePublishInformation publishInfo
- ) {
+ private Mono<HttpStatus> publishFile(FilePublishInformation publishInfo) {
+ MDC.setContextMap(publishInfo.getContext());
logger.trace("Entering publishFile with {}", publishInfo);
try {
HttpPut put = new HttpPut();