1 files changed, 10 insertions, 0 deletions
diff --git a/src/main/java/org/onap/dcae/controller/AccessController.java b/src/main/java/org/onap/dcae/controller/AccessController.java
index daf6237..5050b4b 100644
--- a/src/main/java/org/onap/dcae/controller/AccessController.java
+++ b/src/main/java/org/onap/dcae/controller/AccessController.java
@@ -294,4 +294,14 @@ public class AccessController {
             fetchTokenId();
         }
     }
+
+    public void clearAllPersistentConnectios() {
+        log.info("clearAll PersistentConnectios !");
+        for (java.util.Map.Entry<String, PersistentEventConnection> entry : eventList.entrySet()) {
+            PersistentEventConnection conn = entry.getValue();
+            conn.shutdown();
+        }
+        accesstokenRenewal.cancel(true);
+        scheduledThreadPoolExecutor.shutdown();
+    }
 }