summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main
diff options
context:
space:
mode:
authorMarcin Migdal <marcin.migdal@nokia.com>2019-04-03 15:52:22 +0200
committerMarcin Migdal <marcin.migdal@nokia.com>2019-04-03 15:52:22 +0200
commit7bd496f977edaca0c902e925153c6ca7a0a9b31e (patch)
treea143368ee3d5aee72b8c0b3df4a30fd1fe0c1d60 /prh-app-server/src/main
parenta9dfad25c62ec8b4ed1bd04f4b51a59581431a85 (diff)
Align PRH to newest SDK
Change-Id: I961c83cd230b521ee13c7146d7f0e98d805e6d47 Issue-ID: DCAEGEN2-1361 Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
Diffstat (limited to 'prh-app-server/src/main')
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/BbsActionsTaskImpl.java9
1 files changed, 5 insertions, 4 deletions
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<ByteBuf> 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<String, String> aaiHeaders = HashMap
@@ -116,7 +117,7 @@ public class BbsActionsTaskImpl implements BbsActionsTask {
.builder()
.method(PUT)
.url(uri)
- .body(jsonPayload)
+ .body(requestBody)
.customHeaders(aaiHeaders)
.build();
}