From 7bd496f977edaca0c902e925153c6ca7a0a9b31e Mon Sep 17 00:00:00 2001 From: Marcin Migdal Date: Wed, 3 Apr 2019 15:52:22 +0200 Subject: Align PRH to newest SDK Change-Id: I961c83cd230b521ee13c7146d7f0e98d805e6d47 Issue-ID: DCAEGEN2-1361 Signed-off-by: Marcin Migdal --- .../org/onap/dcaegen2/services/prh/tasks/BbsActionsTaskImpl.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'prh-app-server/src/main/java') diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/BbsActionsTaskImpl.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/BbsActionsTaskImpl.java index 9648efdf..eb5b51a1 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/BbsActionsTaskImpl.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/BbsActionsTaskImpl.java @@ -21,7 +21,6 @@ package org.onap.dcaegen2.services.prh.tasks; import com.google.gson.JsonObject; -import io.netty.buffer.ByteBuf; import io.vavr.collection.HashMap; import io.vavr.collection.Map; import org.onap.dcaegen2.services.prh.configuration.Config; @@ -39,13 +38,15 @@ import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.RequestBody; import org.onap.dcaegen2.services.sdk.rest.services.adapters.http.RxHttpClient; import org.onap.dcaegen2.services.sdk.rest.services.uri.URI.URIBuilder; import org.onap.dcaegen2.services.sdk.security.ssl.SslFactory; -import org.reactivestreams.Publisher; + import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import reactor.core.publisher.Mono; + + import java.util.Arrays; import java.util.List; import java.util.function.Function; @@ -105,7 +106,7 @@ public class BbsActionsTaskImpl implements BbsActionsTask { private ImmutableHttpRequest buildLogicalLinkRequest(String linkName, String pnfName) { String uri = buildLogicalLinkUri(linkName); ImmutableLogicalLink logicalLink = buildModel(linkName, pnfName); - Publisher jsonPayload = RequestBody.fromString(GsonSerializer.createJsonBody(logicalLink)); + RequestBody requestBody = RequestBody.fromString(GsonSerializer.createJsonBody(logicalLink)); // FIXME: AAI headers for PUT are different than PATCH (taken from prh_endpoints.json) Map aaiHeaders = HashMap @@ -116,7 +117,7 @@ public class BbsActionsTaskImpl implements BbsActionsTask { .builder() .method(PUT) .url(uri) - .body(jsonPayload) + .body(requestBody) .customHeaders(aaiHeaders) .build(); } -- cgit 1.2.3-korg