summaryrefslogtreecommitdiffstats
path: root/PolicyEngineAPI/src/main/java/org
diff options
context:
space:
mode:
authorPamela Dragosh <pdragosh@research.att.com>2018-05-01 13:52:30 +0000
committerGerrit Code Review <gerrit@onap.org>2018-05-01 13:52:30 +0000
commit681b47487c22be6dda452501ead10b4c7d7e9c56 (patch)
tree22979df5638510f3297a100f7171740ce14edefc /PolicyEngineAPI/src/main/java/org
parent1c022346cd42f3458816ac1e40d49efac9ae5c6b (diff)
parent6cf6acc675589e271e4e3d1256a7e04eb7bf8a27 (diff)
Merge "Remove sysout from junit and disable assert."
Diffstat (limited to 'PolicyEngineAPI/src/main/java/org')
-rw-r--r--PolicyEngineAPI/src/main/java/org/onap/policy/std/AutoClientEnd.java4
-rw-r--r--PolicyEngineAPI/src/main/java/org/onap/policy/std/ManualClientEnd.java1
2 files changed, 4 insertions, 1 deletions
diff --git a/PolicyEngineAPI/src/main/java/org/onap/policy/std/AutoClientEnd.java b/PolicyEngineAPI/src/main/java/org/onap/policy/std/AutoClientEnd.java
index 00c8c5f0a..aabda96c8 100644
--- a/PolicyEngineAPI/src/main/java/org/onap/policy/std/AutoClientEnd.java
+++ b/PolicyEngineAPI/src/main/java/org/onap/policy/std/AutoClientEnd.java
@@ -148,6 +148,7 @@ public class AutoClientEnd extends WebSocketClient {
try {
logger.info("Starting Auto Notification with the PDP server : " + url);
client = new AutoClientEnd(new URI(url + "notifications"));
+ client.setConnectionLostTimeout(0);
client.connect();
status = true;
restartExecutorService = Executors.newSingleThreadScheduledExecutor();
@@ -212,6 +213,7 @@ public class AutoClientEnd extends WebSocketClient {
}
private static void callHandler() {
+ logger.info("AutoClientEnd: In callHandler");
if (handler == null || scheme == null) {
return;
}
@@ -245,4 +247,4 @@ public class AutoClientEnd extends WebSocketClient {
}
}
}
-}
+} \ No newline at end of file
diff --git a/PolicyEngineAPI/src/main/java/org/onap/policy/std/ManualClientEnd.java b/PolicyEngineAPI/src/main/java/org/onap/policy/std/ManualClientEnd.java
index a67b5402e..778acd716 100644
--- a/PolicyEngineAPI/src/main/java/org/onap/policy/std/ManualClientEnd.java
+++ b/PolicyEngineAPI/src/main/java/org/onap/policy/std/ManualClientEnd.java
@@ -90,6 +90,7 @@ public class ManualClientEnd extends WebSocketClient {
try {
client = new ManualClientEnd(new URI(url + "notifications"));
+ client.setConnectionLostTimeout(0);
client.connect();
latch.await();
client.closeBlocking();