diff options
Diffstat (limited to 'src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java')
| -rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java | 17 |
1 files changed, 13 insertions, 4 deletions
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 688bbce..9c3fa4e 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java +++ b/src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java @@ -76,15 +76,24 @@ public class MrProvConnection extends BaseLoggingClass{ public boolean makeTopicConnection( MR_Cluster cluster ) { - logger.info( "connect to cluster: " + cluster.getDcaeLocationName()); - + boolean rc = false; + logger.info( "connect to cluster: " + cluster.getDcaeLocationName()); + provURL = cluster.getTopicProtocol() + "://" + cluster.getFqdn() + ":" + cluster.getTopicPort() + "/topics/create"; if ( cluster.getTopicProtocol().equals( "https" ) ) { - return makeSecureConnection( provURL ); + rc = makeSecureConnection( provURL ); + } else { + rc = makeConnection( provURL ); } - return makeConnection( provURL ); + if ( rc && unit_test.equals( "Yes" ) ) { + // set timeouts low so we don't hold up unit tests in build process + uc.setReadTimeout(5); + uc.setConnectTimeout(5); + } + return rc; + } private boolean makeSecureConnection( String pURL ) { |