diff options
Diffstat (limited to 'appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/http/HttpDmaapProducerImpl.java')
-rw-r--r-- | appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/http/HttpDmaapProducerImpl.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/http/HttpDmaapProducerImpl.java b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/http/HttpDmaapProducerImpl.java index ca3420a2c..3a986c31e 100644 --- a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/http/HttpDmaapProducerImpl.java +++ b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/http/HttpDmaapProducerImpl.java @@ -68,12 +68,14 @@ public class HttpDmaapProducerImpl extends CommonHttpClient implements Producer @Override public boolean post(String partition, String data) { + LOG.debug("Entering HttpDmaapProducerImpl::: post "); long sent = 0; try { HttpPost request = postReq(null); request.setHeader("Content-Type", CONTENT_TYPE); request.setEntity(new StringEntity(bodyLine(partition, data))); + LOG.debug("Before sendRequest HttpDmaapProducerImpl::: post "); sent = topics.stream() .filter(topic -> sendRequest(request, topic)) .count(); @@ -84,6 +86,7 @@ public class HttpDmaapProducerImpl extends CommonHttpClient implements Producer data, buildEx.getMessage()), buildEx); } + LOG.debug("Exiting HttpDmaapProducerImpl::: post "); return sent == topics.size(); } @@ -92,10 +95,15 @@ public class HttpDmaapProducerImpl extends CommonHttpClient implements Producer String uriStr = String.format(URL_TEMPLATE, hosts.get(0), topic); try { request.setURI(new URI(uriStr)); + LOG.debug("HttpDmaapProducerImpl::: before sendRequest()"); CloseableHttpResponse response = getClient().execute(request); + LOG.debug("HttpDmaapProducerImpl::: after sendRequest()"); if (response.getStatusLine().getStatusCode() == 200) { successful = true; } + else { + LOG.debug("HttpDmaapProducerImpl::: did not receive 200 for sendRequest"); + } response.close(); } catch (Exception sendEx) { LOG.error(String.format("Failed to send message to %s. Reason: %s", uriStr, sendEx.getMessage()), |