More logging added to debug

[appc.git] / appc-adapters / appc-dmaap-adapter / appc-dmaap-adapter-bundle / src / main / java / org / onap / appc / adapter / messaging / dmaap / http / HttpDmaapProducerImpl.java

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 ca3420a..3a986c3 100644 (file)
--- 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()),