diff options
Diffstat (limited to 'src/main/java/org/onap/dcaegen2/services/pmmapper/utils/DmaapRequestSender.java')
| -rw-r--r-- | src/main/java/org/onap/dcaegen2/services/pmmapper/utils/DmaapRequestSender.java | 20 |
1 files changed, 15 insertions, 5 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/DmaapRequestSender.java b/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/DmaapRequestSender.java index 1a7c59e..e7898af 100644 --- a/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/DmaapRequestSender.java +++ b/src/main/java/org/onap/dcaegen2/services/pmmapper/utils/DmaapRequestSender.java @@ -1,6 +1,6 @@ /*- * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nokia. + * Copyright (C) 2021-2022 Nokia. All rights reserved. * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -25,6 +25,7 @@ import com.google.gson.JsonParser; import io.vavr.control.Try; import org.onap.dcaegen2.services.sdk.model.streams.AafCredentials; import org.onap.dcaegen2.services.sdk.model.streams.dmaap.ImmutableMessageRouterSink; +import org.onap.dcaegen2.services.sdk.model.streams.dmaap.ImmutableMessageRouterSink.Builder; import org.onap.dcaegen2.services.sdk.model.streams.dmaap.MessageRouterSink; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.ContentType; import org.onap.dcaegen2.services.sdk.rest.services.dmaap.client.api.DmaapClientFactory; @@ -88,10 +89,19 @@ public class DmaapRequestSender { } private static MessageRouterSink sink(String topicUrl, AafCredentials credentials) { - return ImmutableMessageRouterSink.builder() - .aafCredentials(credentials) - .topicUrl(topicUrl) - .build(); + Builder builder = ImmutableMessageRouterSink.builder(); + if (credentialsExists(credentials)) { + builder.aafCredentials(credentials); + } + return builder.topicUrl(topicUrl).build(); + } + + private static boolean credentialsExists(AafCredentials credentials) { + return isNotBlank(credentials.username()) && isNotBlank(credentials.password()); + } + + private static boolean isNotBlank(String str) { + return str != null && !str.isEmpty(); } private static RequestDiagnosticContext diagnosticContext() { |