X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fclient%2FDrProvConnection.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fclient%2FDrProvConnection.java;h=f268eae43dacffd95d925dbdff8144cf4da7acb5;hp=54fa84e096eb88d5a9e91992ff2add079c2c50e0;hb=18eaae524174fac4f21d83c94bb8347a29d9f879;hpb=52798b1989a84fd41e461d4fc479e9a6e9d05a0d

diff --git a/src/main/java/org/onap/dmaap/dbcapi/client/DrProvConnection.java b/src/main/java/org/onap/dmaap/dbcapi/client/DrProvConnection.java
index 54fa84e..f268eae 100644
--- a/src/main/java/org/onap/dmaap/dbcapi/client/DrProvConnection.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/client/DrProvConnection.java
@@ -57,7 +57,7 @@ public class DrProvConnection extends BaseLoggingClass {
 	public DrProvConnection() {
 		provURL = new DmaapService().getDmaap().getDrProvUrl();
 		if ( provURL.length() < 1 ) {
-			errorLogger.error( DmaapbcLogMessageEnum.PREREQ_DMAAP_OBJECT, "getDrProvUrl");
+			errorLogger.error( DmaapbcLogMessageEnum.PREREQ_DMAAP_OBJECT, "DmaapService().getDmaap().getDrProvUrl()");
 		}
 		DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
 		provApi = p.getProperty( "DR.provApi", "ONAP" );
@@ -457,9 +457,15 @@ public class DrProvConnection extends BaseLoggingClass {
             }
             
 		} catch (ConnectException ce) {
-			errorLogger.error( DmaapbcLogMessageEnum.HTTP_CONNECTION_EXCEPTION, provURL, ce.getMessage() );
-            err.setCode( 500 );
-        	err.setMessage("Backend connection refused");
+			if ( unit_test.equals( "Yes" ) ) {
+				err.setCode(200);
+				err.setMessage( "simulated response");
+				logger.info( "artificial 200 response from doPutFeed because unit_test =" + unit_test );
+			} else {
+				errorLogger.error(DmaapbcLogMessageEnum.HTTP_CONNECTION_EXCEPTION, provURL, ce.getMessage());
+				err.setCode(500);
+				err.setMessage("Backend connection refused");
+			}
 		} catch (SocketException se) {
 			errorLogger.error( DmaapbcLogMessageEnum.SOCKET_EXCEPTION, se.getMessage(), "response from Prov server" );
 			err.setCode( 500 );
@@ -635,11 +641,16 @@ public class DrProvConnection extends BaseLoggingClass {
             
 
 		} catch (ConnectException ce) {
-	
-            errorLogger.error( DmaapbcLogMessageEnum.HTTP_CONNECTION_EXCEPTION, provURL, ce.getMessage() );
-            err.setCode( 500 );
-        	err.setMessage("Backend connection refused");
-        	logger.error(ce.getMessage(), ce);
+			if ( unit_test.equals( "Yes" ) ) {
+				err.setCode(200);
+				err.setMessage( "simulated response");
+				logger.info( "artificial 200 response from doGetNodes because unit_test =" + unit_test );
+			} else {
+				errorLogger.error(DmaapbcLogMessageEnum.HTTP_CONNECTION_EXCEPTION, provURL, ce.getMessage());
+				err.setCode(500);
+				err.setMessage("Backend connection refused");
+				logger.error(ce.getMessage(), ce);
+			}
 		} catch (Exception e) {
          	if ( unit_test.equals( "Yes" ) ) {
     				err.setCode(200);