1 files changed, 40 insertions, 38 deletions

diff --git a/mso-api-handlers/mso-api-handler-common/src/main/java/org/openecomp/mso/apihandler/common/ResponseHandler.java b/mso-api-handlers/mso-api-handler-common/src/main/java/org/openecomp/mso/apihandler/common/ResponseHandler.java
index 732b7786b2..a8b8984343 100644
--- a/mso-api-handlers/mso-api-handler-common/src/main/java/org/openecomp/mso/apihandler/common/ResponseHandler.java
+++ b/mso-api-handlers/mso-api-handler-common/src/main/java/org/openecomp/mso/apihandler/common/ResponseHandler.java
@@ -27,21 +27,22 @@ import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
 import org.apache.http.HttpStatus;
 import org.apache.http.util.EntityUtils;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
 import org.openecomp.mso.apihandler.camundabeans.CamundaResponse;
-import org.openecomp.mso.logger.MsoLogger;
 import org.openecomp.mso.logger.MessageEnum;
+import org.openecomp.mso.logger.MsoLogger;
+import org.openecomp.mso.utils.RootIgnoringObjectMapper;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
 
 public class ResponseHandler {
 
 	private CamundaResponse response;
 	private int status;
-	private String responseBody="";
+	private String content = "";
 	private HttpResponse httpResponse;
 	private int type;
 	private static MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.APIH);
-    private static final String RESPONSE_BODY_MSG = "response body is: ";
+    private static final String RESPONSE_CONTENT_MSG = "response content is: ";
 
 	public ResponseHandler(HttpResponse httpResponse, int type) {
 		this.httpResponse = httpResponse;
@@ -67,29 +68,31 @@ public class ResponseHandler {
 	
 
 	
+	@SuppressWarnings("unchecked")
 	private void parseCamunda(){
 		try{
-				HttpEntity entity = httpResponse.getEntity();
-				responseBody = EntityUtils.toString(entity);
-			} catch (IOException e) {
-				msoLogger.debug("IOException getting Camunda response body", e);
-			}
-		
-			ObjectMapper mapper = new ObjectMapper(); 
-			try {
-				response = mapper.readValue(responseBody, CamundaResponse.class);
-			} catch (IOException e) {
-				msoLogger.debug("IOException getting Camunda response body", e);
-			}
-			msoLogger.debug("json response is: " + responseBody);
-			if(response!=null){
-				responseBody = response.getResponse();
-			}
-			msoLogger.debug(RESPONSE_BODY_MSG + responseBody);
-			
-		
+			HttpEntity entity = httpResponse.getEntity();
+			content = EntityUtils.toString(entity);
+		} catch (IOException e) {
+			msoLogger.debug("IOException getting Camunda response content", e);
+		}
+
+		ObjectMapper mapper = new RootIgnoringObjectMapper<CamundaResponse>(CamundaResponse.class);
+
+		try {
+			response = mapper.readValue(content, CamundaResponse.class);
+		} catch (IOException e) {
+			msoLogger.debug("IOException getting Camunda response content", e);
+		}
+		msoLogger.debug("json response is: " + content);
+		if(response!=null){
+			content = response.getContent();
+		}
+		msoLogger.debug(RESPONSE_CONTENT_MSG + content);
+
+
 		if(status!=HttpStatus.SC_ACCEPTED){
-			msoLogger.error(MessageEnum.APIH_ERROR_FROM_BPEL_SERVER, "Camunda", String.valueOf(status), responseBody, "Camunda", "parseCamunda", MsoLogger.ErrorCode.BusinessProcesssError, "Error in APIH from Camunda");
+			msoLogger.error(MessageEnum.APIH_ERROR_FROM_BPEL_SERVER, "Camunda", String.valueOf(status), content, "Camunda", "parseCamunda", MsoLogger.ErrorCode.BusinessProcesssError, "Error in APIH from Camunda");
 		}
 	}
 	
@@ -99,16 +102,16 @@ public class ResponseHandler {
 
 		try {
 			if (bpelEntity!=null) {
-				responseBody = EntityUtils.toString(bpelEntity);
-				msoLogger.debug(RESPONSE_BODY_MSG + responseBody);
+				content = EntityUtils.toString(bpelEntity);
+				msoLogger.debug(RESPONSE_CONTENT_MSG + content);
 
 			}
 			if(status!=HttpStatus.SC_ACCEPTED){
-				msoLogger.error(MessageEnum.APIH_ERROR_FROM_BPEL_SERVER, "BPEL", String.valueOf(status), responseBody, "BPEL", "parseBpel", MsoLogger.ErrorCode.BusinessProcesssError, "Error in APIH from BPEL");
+				msoLogger.error(MessageEnum.APIH_ERROR_FROM_BPEL_SERVER, "BPEL", String.valueOf(status), content, "BPEL", "parseBpel", MsoLogger.ErrorCode.BusinessProcesssError, "Error in APIH from BPEL");
 			}
 		} 
 		catch (IOException e) {
-			msoLogger.debug("IOException getting BPEL response body", e);
+			msoLogger.debug("IOException getting BPEL response content", e);
 		}
 	}
 	
@@ -118,16 +121,16 @@ public class ResponseHandler {
 
 		try {
 			if (camundataskEntity!=null) {
-				responseBody = EntityUtils.toString(camundataskEntity);
-				msoLogger.debug(RESPONSE_BODY_MSG + responseBody);
+				content = EntityUtils.toString(camundataskEntity);
+				msoLogger.debug(RESPONSE_CONTENT_MSG + content);
 
 			}
 			if(status!=HttpStatus.SC_NO_CONTENT && status != HttpStatus.SC_ACCEPTED){
-				msoLogger.error(MessageEnum.APIH_ERROR_FROM_BPEL_SERVER, "CAMUNDATASK", String.valueOf(status), responseBody, "CAMUNDATASK", "parseCamundaTask", MsoLogger.ErrorCode.BusinessProcesssError, "Error in APIH from Camunda Task");
+				msoLogger.error(MessageEnum.APIH_ERROR_FROM_BPEL_SERVER, "CAMUNDATASK", String.valueOf(status), content, "CAMUNDATASK", "parseCamundaTask", MsoLogger.ErrorCode.BusinessProcesssError, "Error in APIH from Camunda Task");
 			}
 		} 
 		catch (IOException e) {
-			msoLogger.debug("IOException getting Camunda Task response body", e);
+			msoLogger.debug("IOException getting Camunda Task response content", e);
 		}
 	}
 
@@ -175,18 +178,17 @@ public class ResponseHandler {
 	}
 
 
-	public String getResponseBody() {
-		return responseBody;
+	public String getContent() {
+		return content;
 	}
 
 
-	public void setResponseBody(String responseBody) {
-		this.responseBody = responseBody;
+	public void setContent(String content) {
+		this.content = content;
 	}
 
 
 	public int getStatus() {
 		return status;
 	}
-
 }