diff options
author | pwielebs <piotr.wielebski@nokia.com> | 2018-05-07 16:58:20 +0200 |
---|---|---|
committer | pwielebs <piotr.wielebski@nokia.com> | 2018-05-11 12:29:25 +0200 |
commit | a393ae34963a919b842127cc8943a94f2d7c1bc7 (patch) | |
tree | 666c78e8d10b0fd65e55494e2e27d52643cf92a2 /prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java | |
parent | 8c88efe7a0abe051e8a4c4d271c84eb8e68c29f0 (diff) |
AAI client configuration & tasks changed
Change-Id: I86a2f2ed62565263f2be2c9078a092f993234a19
Issue-ID: DCAEGEN2-451
Signed-off-by: pwielebs <piotr.wielebski@nokia.com>
Diffstat (limited to 'prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java')
-rw-r--r-- | prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java | 29 |
1 files changed, 11 insertions, 18 deletions
diff --git a/prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java b/prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java index 98c9a83e..def9dd85 100644 --- a/prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java +++ b/prh-dmaap-client/src/main/java/org/onap/dcaegen2/services/service/producer/ExtendedDmaapProducerHttpClientImpl.java @@ -29,6 +29,8 @@ import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.util.EntityUtils; import org.onap.dcaegen2.services.config.DmaapPublisherConfiguration; +import org.onap.dcaegen2.services.model.CommonFunctions; +import org.onap.dcaegen2.services.model.ConsumerDmaapModel; import org.onap.dcaegen2.services.service.DmaapHttpClientImpl; import org.onap.dcaegen2.services.service.HttpUtils; import org.slf4j.Logger; @@ -61,17 +63,14 @@ public class ExtendedDmaapProducerHttpClientImpl { this.dmaapContentType = configuration.dmaapContentType(); } - public Optional<String> getHttpProducerResponse(DmaapPublisherRequestDetails requestDetails) { - + public Optional<String> getHttpProducerResponse(ConsumerDmaapModel consumerDmaapModel) { Optional<String> extendedDetails = Optional.empty(); - Optional<HttpRequestBase> request = createRequest(requestDetails); - + Optional<HttpRequestBase> request = createRequest(consumerDmaapModel); try { extendedDetails = closeableHttpClient.execute(request.get(), dmaapProducerResponseHandler()); } catch (IOException | NullPointerException e) { logger.warn("Exception while executing HTTP request: ", e); } - return extendedDetails; } @@ -81,51 +80,45 @@ public class ExtendedDmaapProducerHttpClientImpl { private Optional<StringEntity> parseJson(Optional<String> jsonBody) { Optional<StringEntity> stringEntity = Optional.empty(); - try { stringEntity = Optional.of(new StringEntity(jsonBody.get())); } catch (UnsupportedEncodingException e) { logger.warn("Exception while parsing JSON: ", e); } - return stringEntity; } - private Optional<HttpRequestBase> createRequest(DmaapPublisherRequestDetails requestDetails) { - + private Optional<HttpRequestBase> createRequest(ConsumerDmaapModel consumerDmaapModel) { Optional<HttpRequestBase> request = Optional.empty(); - final URI extendedURI = createDmaapPublisherExtendedURI(requestDetails); + final URI extendedURI = createDmaapPublisherExtendedURI(); if ("application/json".equals(dmaapContentType)) { - request = Optional.ofNullable(createRequest(extendedURI, requestDetails)); + request = Optional.ofNullable(createRequest(extendedURI, consumerDmaapModel)); request.get().addHeader("Content-type", dmaapContentType); } return request; } - private URI createDmaapPublisherExtendedURI(DmaapPublisherRequestDetails requestDetails) { + private URI createDmaapPublisherExtendedURI() { URI extendedURI = null; - final URIBuilder uriBuilder = new URIBuilder() .setScheme(dmaapProtocol) .setHost(dmaapHostName) .setPort(dmaapPortNumber) - .setPath(requestDetails.dmaapAPIPath() + "/" + dmaapTopicName); - + .setPath(dmaapTopicName); try { extendedURI = uriBuilder.build(); logger.trace("Building extended URI: {}", extendedURI); } catch (URISyntaxException e) { logger.warn("Exception while building extended URI: ", e); } - return extendedURI; } - private HttpRequestBase createRequest(URI extendedURI, DmaapPublisherRequestDetails requestDetails) { + private HttpRequestBase createRequest(URI extendedURI, ConsumerDmaapModel consumerDmaapModel) { if (extendedURI != null) { - return createHttpPost(extendedURI, Optional.ofNullable(requestDetails.jsonBody())); + return createHttpPost(extendedURI, Optional.ofNullable(CommonFunctions.createJsonBody(consumerDmaapModel))); } else { return null; } |