diff options
author | Pamela Dragosh <pdragosh@research.att.com> | 2018-05-01 13:52:30 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2018-05-01 13:52:30 +0000 |
commit | 681b47487c22be6dda452501ead10b4c7d7e9c56 (patch) | |
tree | 22979df5638510f3297a100f7171740ce14edefc /PolicyEngineAPI/src/main/java/org | |
parent | 1c022346cd42f3458816ac1e40d49efac9ae5c6b (diff) | |
parent | 6cf6acc675589e271e4e3d1256a7e04eb7bf8a27 (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.java | 4 | ||||
-rw-r--r-- | PolicyEngineAPI/src/main/java/org/onap/policy/std/ManualClientEnd.java | 1 |
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(); |