summaryrefslogtreecommitdiffstats
path: root/PolicyEngineAPI/src/main/java/org
diff options
context:
space:
mode:
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();