X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Faaf%2Fclient%2FMrTopicConnection.java;h=bfbe826c6b815d205c6974ad726abc114b466391;hp=0b4937931009f5784866cc243c897ef383217ab3;hb=503da874ce876dbe463bcc1a03f63ea0f48fe650;hpb=0afd0dd2f1fa4435fa730a287e68fec4f271e617

diff --git a/src/main/java/org/onap/dmaap/dbcapi/aaf/client/MrTopicConnection.java b/src/main/java/org/onap/dmaap/dbcapi/aaf/client/MrTopicConnection.java
index 0b49379..bfbe826 100644
--- a/src/main/java/org/onap/dmaap/dbcapi/aaf/client/MrTopicConnection.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/aaf/client/MrTopicConnection.java
@@ -36,6 +36,7 @@ import org.apache.log4j.Logger;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.model.ApiError;
 import org.onap.dmaap.dbcapi.model.MR_Cluster;
+import org.onap.dmaap.dbcapi.util.DmaapConfig;
 
 public class MrTopicConnection extends BaseLoggingClass  {
 	private String topicURL;
@@ -44,12 +45,14 @@ public class MrTopicConnection extends BaseLoggingClass  {
 
 	
 	private  String mmProvCred; 
+	private	String unit_test;
 	
 
 
 	public MrTopicConnection(String user, String pwd ) {
 		mmProvCred = new String( user + ":" + pwd );
-
+		DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
+        unit_test = p.getProperty( "UnitTest", "No" );
 	}
 	
 	public boolean makeTopicConnection( MR_Cluster cluster, String topic, String overrideFqdn ) {
@@ -159,10 +162,17 @@ public class MrTopicConnection extends BaseLoggingClass  {
             } 
             
 		} catch (Exception e) {
-			response.setCode(500);
-			response.setMessage( "Unable to read response");
-			logger.warn( response.getMessage() );
-            e.printStackTrace();
+        	if ( unit_test.equals( "Yes" ) ) {
+				response.setCode(200);
+				response.setMessage( "simulated response");
+				logger.info( "artificial 200 response from doPostMessage because unit_test =" + unit_test );
+        	} else {
+
+				response.setCode(500);
+				response.setMessage( "Unable to read response");
+				logger.warn( response.getMessage() );
+            	e.printStackTrace();
+			}
         }
 		finally {
 			try {