Adding new LCM features to the client lib

[appc.git] / appc-client / client-lib / src / main / java / org / onap / appc / client / impl / protocol / ConsumerImpl.java

diff --git a/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/protocol/ConsumerImpl.java b/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/protocol/ConsumerImpl.java
index 913f80f..8fc6788 100644 (file)
--- a/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/protocol/ConsumerImpl.java
+++ b/appc-client/client-lib/src/main/java/org/onap/appc/client/impl/protocol/ConsumerImpl.java
@@ -105,6 +105,14 @@ class ConsumerImpl implements Consumer {
         builder.usingHosts(hosts).onTopic(topic).knownAs(group, groupId);
         builder.withSocketTimeout(timeout + 5000).waitAtServer(timeout);
         builder.receivingAtMost(DEFAULT_LIMIT);
+        
+        //added for loop for defect 354330
+        for (String url : hosts) {
+            if (url.contains("3905") || url.contains("https")) {
+               builder.usingHttps(true);
+                break;
+            }
+        }
 
         // Add credentials if provided
         if (authKey != null && authSecret != null) {