diff options
| author |   wasala <przemyslaw.wasala@nokia.com> | 2018-09-25 12:24:48 +0200 |
|---|---|---|
| committer | wasala <przemyslaw.wasala@nokia.com> | 2018-10-08 07:50:46 +0200 |
| commit | a122d0a0a7075163fad4865143fedf7b6fe511d1 (patch) | |
| tree | ad3034f4f5bdc72a620e2404228925202ba74abe /prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java | |
| parent | f245daa4b205846af33f7a8e088d203c39f24d52 (diff) | |
PRH DMaaP objects batching
*Getting collection of object
in one request
*Refator the workflow
in the old implementation
Change-Id: I4fdbf4bd8ae70cd78dbf5c3c441ba01c28e6ce4f
Issue-ID: DCAEGEN2-834
Signed-off-by: wasala <przemyslaw.wasala@nokia.com>
Diffstat (limited to 'prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java')
| -rw-r--r-- | prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java index 665d65a3..43f6ce91 100644 --- a/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java +++ b/prh-aai-client/src/main/java/org/onap/dcaegen2/services/prh/service/producer/AaiProducerReactiveHttpClient.java @@ -27,7 +27,6 @@ import static org.onap.dcaegen2.services.prh.model.logging.MdcVariables.X_ONAP_R import java.net.URI; import java.util.UUID; - import org.onap.dcaegen2.services.prh.config.AaiClientConfiguration; import org.onap.dcaegen2.services.prh.model.ConsumerDmaapModel; import org.slf4j.MDC; @@ -37,8 +36,6 @@ import org.springframework.web.util.DefaultUriBuilderFactory; import reactor.core.publisher.Mono; - - public class AaiProducerReactiveHttpClient { private WebClient webClient; @@ -90,4 +87,4 @@ public class AaiProducerReactiveHttpClient { return new DefaultUriBuilderFactory().builder().scheme(aaiProtocol).host(aaiHost).port(aaiHostPortNumber) .path(aaiBasePath + aaiPnfPath + "/" + pnfName).build(); } -} +}
\ No newline at end of file |