From e2fc40091989cba8a0fe278712158c8f813d571b Mon Sep 17 00:00:00 2001 From: Piotr Jaszczyk Date: Thu, 11 Apr 2019 09:57:37 +0200 Subject: Enhance dmaap-client v2 * include sent messages in dmaap mr response * split publisher and subscriber * write some unit tests Issue-ID: DCAEGEN2-1421 Change-Id: Ie71e9344efd4a520406b87923413a45d51c28225 Signed-off-by: Piotr Jaszczyk --- .../services/sdk/rest/services/adapters/http/RxHttpClient.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'rest-services/common-dependency') diff --git a/rest-services/common-dependency/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClient.java b/rest-services/common-dependency/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClient.java index 709f5e59..3c010ef2 100644 --- a/rest-services/common-dependency/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClient.java +++ b/rest-services/common-dependency/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/adapters/http/RxHttpClient.java @@ -22,6 +22,7 @@ package org.onap.dcaegen2.services.sdk.rest.services.adapters.http; import io.netty.handler.ssl.SslContext; import io.vavr.collection.Stream; import java.util.stream.Collectors; +import org.jetbrains.annotations.NotNull; import org.onap.dcaegen2.services.sdk.rest.services.model.logging.RequestDiagnosticContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -44,7 +45,8 @@ public class RxHttpClient { } // TODO: hide netty from public api (io.netty.handler.ssl.SslContext) - public static RxHttpClient create(SslContext sslContext) { + public static RxHttpClient create(@NotNull + SslContext sslContext) { return new RxHttpClient(HttpClient.create().secure(sslContextSpec -> sslContextSpec.sslContext(sslContext))); } -- cgit 1.2.3-korg