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%2FMrProvConnection.java;h=a8ace788425a67427fac6e2e9f8db4293dc7457b;hp=91ed1bba76804c77f793b0c05f42539cded1c070;hb=ac03a4b32eae987019cec2cd39d6d252fb320c2f;hpb=fb8a36eeec10b389a3ccc79c5f31ee925243c1b8

diff --git a/src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java b/src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java
index 91ed1bb..a8ace78 100644
--- a/src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java
@@ -26,6 +26,7 @@ import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.OutputStream;
 import java.net.ConnectException;
+import java.net.HttpURLConnection;
 import java.net.ProtocolException;
 import java.net.URL;
 import java.net.UnknownHostException;
@@ -49,7 +50,7 @@ public class MrProvConnection extends BaseLoggingClass{
 	    
 	private String provURL;
 	
-	private HttpsURLConnection uc;
+	private HttpURLConnection uc;
 
 	
 	private String topicMgrCred;
@@ -90,10 +91,13 @@ public class MrProvConnection extends BaseLoggingClass{
 
 		provURL = cluster.getTopicProtocol() + "://" + cluster.getFqdn() + ":" + cluster.getTopicPort() + "/topics/create";
 
+		if ( cluster.getTopicProtocol().equals( "https" ) ) {
+			return makeSecureConnection( provURL );
+		}
 		return makeConnection( provURL );
 	}
 
-	private boolean makeConnection( String pURL ) {
+	private boolean makeSecureConnection( String pURL ) {
 		logger.info( "makeConnection to " + pURL );
 	
 		try {
@@ -111,6 +115,25 @@ public class MrProvConnection extends BaseLoggingClass{
             return(false);
         } 
 
+	}
+	private boolean makeConnection( String pURL ) {
+		logger.info( "makeConnection to " + pURL );
+	
+		try {
+			URL u = new URL( pURL );
+			uc = (HttpURLConnection) u.openConnection();
+			uc.setInstanceFollowRedirects(false);
+			logger.info( "open connect to " + pURL );
+			return(true);
+		} catch( UnknownHostException uhe ){
+        	logger.error( "Caught UnknownHostException for " + pURL);
+        	return(false);
+        } catch (Exception e) {
+            logger.error("Unexpected error during openConnection of " + pURL );
+            e.printStackTrace();
+            return(false);
+        } 
+
 	}
 	
 	static String bodyToString( InputStream is ) {