Issue-ID: APPC-1231
Change-Id: I45790aff545c566fbf62ea1908143b15f3920122
Signed-off-by: Balaji, Ramya (rb111y) <rb111y@att.com>
@Override
public boolean post(String partition, String data) {
@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)));
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();
sent = topics.stream()
.filter(topic -> sendRequest(request, topic))
.count();
data, buildEx.getMessage()),
buildEx);
}
data, buildEx.getMessage()),
buildEx);
}
+ LOG.debug("Exiting HttpDmaapProducerImpl::: post ");
return sent == topics.size();
}
return sent == topics.size();
}
String uriStr = String.format(URL_TEMPLATE, hosts.get(0), topic);
try {
request.setURI(new URI(uriStr));
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);
CloseableHttpResponse response = getClient().execute(request);
+ LOG.debug("HttpDmaapProducerImpl::: after sendRequest()");
if (response.getStatusLine().getStatusCode() == 200) {
successful = true;
}
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()),
response.close();
} catch (Exception sendEx) {
LOG.error(String.format("Failed to send message to %s. Reason: %s", uriStr, sendEx.getMessage()),
@Override
public boolean post(String partition, String data) {
@Override
public boolean post(String partition, String data) {
+ LOG.debug("In DmaapProducerImpl.post()");
boolean success = true;
Properties properties = configuration.getProperties();
if (properties != null && properties.getProperty("metric.enabled") != null) {
boolean success = true;
Properties properties = configuration.getProperties();
if (properties != null && properties.getProperty("metric.enabled") != null) {
LOG.info("Getting CambriaBatchingPublisher Clients ...");
clients = getClients();
}
LOG.info("Getting CambriaBatchingPublisher Clients ...");
clients = getClients();
}
+ LOG.debug("In DmaapProducerImpl.post()::: before sending to clients");
for (MRBatchingPublisher client : clients) {
try {
LOG.debug(String.format("Posting %s to %s", data, client));
for (MRBatchingPublisher client : clients) {
try {
LOG.debug(String.format("Posting %s to %s", data, client));
*/
@Override
public void init(){
*/
@Override
public void init(){
+ logger.debug("MessageAdapterImpl - init");
this.producer = getProducer();
}
this.producer = getProducer();
}
package org.onap.appc.requesthandler.conv;
package org.onap.appc.requesthandler.conv;
+import com.att.aft.dme2.internal.apache.commons.lang3.StringUtils;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
}
public static Payload convAsyncResponseTorev160108Payload(ResponseContext inObj) {
}
public static Payload convAsyncResponseTorev160108Payload(ResponseContext inObj) {
+ logger.debug("Entering convAsyncResponseTorev160108Payload" );
Payload payload = null;
if(inObj.getPayload() != null) {
payload = new Payload(inObj.getPayload());
}
Payload payload = null;
if(inObj.getPayload() != null) {
payload = new Payload(inObj.getPayload());
}
+ logger.debug("Exiting convAsyncResponseTorev160108Payload" );
}
public static Status convAsyncResponseTorev160108Status(ResponseContext inObj) {
}
public static Status convAsyncResponseTorev160108Status(ResponseContext inObj) {
+ logger.debug("Entering convAsyncResponseTorev160108Status");
StatusBuilder statusBuilder = new StatusBuilder();
statusBuilder.setCode(inObj.getStatus().getCode());
statusBuilder.setMessage(inObj.getStatus().getMessage());
StatusBuilder statusBuilder = new StatusBuilder();
statusBuilder.setCode(inObj.getStatus().getCode());
statusBuilder.setMessage(inObj.getStatus().getMessage());
+ logger.debug("Exiting convAsyncResponseTorev160108Status");
return statusBuilder.build();
}
public static CommonHeader convAsyncResponseTorev160108CommonHeader(ResponseContext inObj) {
return statusBuilder.build();
}
public static CommonHeader convAsyncResponseTorev160108CommonHeader(ResponseContext inObj) {
+ logger.debug("Entered into convAsyncResponseTorev160108CommonHeader");
CommonHeader outObj = null;
if(inObj == null){
throw new IllegalArgumentException("empty asyncResponse");
CommonHeader outObj = null;
if(inObj == null){
throw new IllegalArgumentException("empty asyncResponse");
commonHeaderBuilder.setFlags(commonHeaderFlags);
}
commonHeaderBuilder.setFlags(commonHeaderFlags);
}
+ logger.debug("Before setApiVer");
commonHeaderBuilder.setApiVer(inObj.getCommonHeader().getApiVer());
commonHeaderBuilder.setRequestId(inObj.getCommonHeader().getRequestId());
if(inObj.getCommonHeader().getSubRequestId() != null){
commonHeaderBuilder.setSubRequestId(inObj.getCommonHeader().getSubRequestId());
}
commonHeaderBuilder.setApiVer(inObj.getCommonHeader().getApiVer());
commonHeaderBuilder.setRequestId(inObj.getCommonHeader().getRequestId());
if(inObj.getCommonHeader().getSubRequestId() != null){
commonHeaderBuilder.setSubRequestId(inObj.getCommonHeader().getSubRequestId());
}
+ logger.debug("Before getOriginatorId");
if(inObj.getCommonHeader().getOriginatorId() != null){
commonHeaderBuilder.setOriginatorId(inObj.getCommonHeader().getOriginatorId());
}
if(inObj.getCommonHeader().getOriginatorId() != null){
commonHeaderBuilder.setOriginatorId(inObj.getCommonHeader().getOriginatorId());
}
+ logger.debug("Before getTimeStamp");
if(inObj.getCommonHeader().getTimeStamp() != null){
String zuluTimestampStr = Converter.convDateToZuluString(inObj.getCommonHeader().getTimeStamp());
if(inObj.getCommonHeader().getTimeStamp() != null){
String zuluTimestampStr = Converter.convDateToZuluString(inObj.getCommonHeader().getTimeStamp());
+ logger.debug("After invoking convDateToZuluString()");
ZULU zuluTimestamp = new ZULU(zuluTimestampStr);
ZULU zuluTimestamp = new ZULU(zuluTimestampStr);
+ logger.debug("After ZULU()");
commonHeaderBuilder.setTimestamp(zuluTimestamp);
}
outObj = commonHeaderBuilder.build();
commonHeaderBuilder.setTimestamp(zuluTimestamp);
}
outObj = commonHeaderBuilder.build();
+ logger.debug("Exiting from convAsyncResponseTorev160108CommonHeader: Returning outObj::"+outObj.toString());
outObj.setCorrelationID(correlationID);
outObj.setType("response");
outObj.setRpcName(rpcName);
outObj.setCorrelationID(correlationID);
outObj.setType("response");
outObj.setRpcName(rpcName);
+ logger.debug("In onverter.convAsyncResponseToDmaapOutgoingMessage() before invoking convAsyncResponseToBuilder");
Builder<?> builder = Converter.convAsyncResponseToBuilder(vnfOperation, rpcName, asyncResponse);
Object messageBody = builder.build();
DmaapOutgoingMessage.Body body = new DmaapOutgoingMessage.Body(messageBody);
Builder<?> builder = Converter.convAsyncResponseToBuilder(vnfOperation, rpcName, asyncResponse);
Object messageBody = builder.build();
DmaapOutgoingMessage.Body body = new DmaapOutgoingMessage.Body(messageBody);