aboutsummaryrefslogtreecommitdiffstats
path: root/rest-services/dmaap-client/src/main/java
diff options
context:
space:
mode:
authorMarcin Migdal <marcin.migdal@nokia.com>2019-03-08 15:49:58 +0100
committerMarcin Migdal <marcin.migdal@nokia.com>2019-03-08 15:50:03 +0100
commita557b012ab5c51f9a5fb88328eb678eb78091118 (patch)
tree5a096caf4631f411c5052664d80616b4a825f4ed /rest-services/dmaap-client/src/main/java
parent186f69f3c3a17e0004ab6771cc5adac6a4722023 (diff)
Change CloudHttpClient API
Change-Id: Icbbe871e71c6bb46aba7411b9f9016af14c5eab9 Issue-ID: DCAEGEN2-1310 Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
Diffstat (limited to 'rest-services/dmaap-client/src/main/java')
-rw-r--r--rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/service/producer/DMaaPPublisherReactiveHttpClient.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/service/producer/DMaaPPublisherReactiveHttpClient.java b/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/service/producer/DMaaPPublisherReactiveHttpClient.java
index 6314bcba..84596cde 100644
--- a/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/service/producer/DMaaPPublisherReactiveHttpClient.java
+++ b/rest-services/dmaap-client/src/main/java/org/onap/dcaegen2/services/sdk/rest/services/dmaap/client/service/producer/DMaaPPublisherReactiveHttpClient.java
@@ -33,6 +33,7 @@ import org.onap.dcaegen2.services.sdk.rest.services.model.JsonBodyBuilder;
import org.onap.dcaegen2.services.sdk.rest.services.model.logging.RequestDiagnosticContext;
import org.onap.dcaegen2.services.sdk.rest.services.uri.URI.URIBuilder;
import reactor.core.publisher.Mono;
+import reactor.netty.http.client.HttpClientResponse;
/**
@@ -64,7 +65,7 @@ public class DMaaPPublisherReactiveHttpClient extends DMaaPAbstractReactiveHttpC
* @return status code of operation
*/
- public Mono<Integer> getDMaaPProducerResponse(DmaapModel dmaapModel,
+ public Mono<HttpClientResponse> getDMaaPProducerResponse(DmaapModel dmaapModel,
Optional<RequestDiagnosticContext> requestDiagnosticContextOptional) {
return Mono.defer(() -> {
Map<String, String> headers = DMaaPClientServiceUtils.getHeaders(dmaapPublisherConfiguration.dmaapContentType());