diff options
author | s00370346 <swarup.nayak1@huawei.com> | 2019-05-20 11:02:43 +0530 |
---|---|---|
committer | s00370346 <swarup.nayak1@huawei.com> | 2019-05-20 11:02:43 +0530 |
commit | 45762e8d8a1555957c99f9c8dd995e8542f5d5c3 (patch) | |
tree | 7bd6e61fc6a000ea86b6533f710cc5c44ba58372 /src/main/java/org/onap/dcae/controller/PersistentEventConnection.java | |
parent | d9fc78bff47ad1afa62cec487774a7edbf40147c (diff) |
Issue-ID: DCAEGEN2-1511 Restconfcollector Access Token Renewal
Signed-off-by: s00370346 <swarup.nayak1@huawei.com>
Change-Id: I1b344e734221038bf0b843543f9bf317e9bc09fd
Diffstat (limited to 'src/main/java/org/onap/dcae/controller/PersistentEventConnection.java')
-rw-r--r-- | src/main/java/org/onap/dcae/controller/PersistentEventConnection.java | 23 |
1 files changed, 21 insertions, 2 deletions
diff --git a/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java b/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java index 391da76..48d5448 100644 --- a/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java +++ b/src/main/java/org/onap/dcae/controller/PersistentEventConnection.java @@ -20,8 +20,13 @@ package org.onap.dcae.controller; +import java.nio.file.Files; +import java.nio.file.Path; +import java.nio.file.Paths; import org.glassfish.jersey.media.sse.EventSource; import org.glassfish.jersey.media.sse.SseFeature; +import org.json.JSONArray; +import org.json.JSONObject; import org.onap.dcae.common.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -187,8 +192,13 @@ public class PersistentEventConnection implements Runnable { parentCtrllr.getRestApiCallNode().sendRequest(eventParaMap, ctx, null); } catch (Exception e) { - log.error("Exception occured!", e); - Thread.currentThread().interrupt(); + log.error("Failed to receive sbscription notiication, trying again", e); + try { + parentCtrllr.getRestApiCallNode().sendRequest(eventParaMap, ctx, null); + }catch (Exception ex){ + log.error("Exception occured again! Trying again", e); + Thread.currentThread().interrupt(); + } } /* Retrieve url from result and construct SSE url */ @@ -222,6 +232,7 @@ public class PersistentEventConnection implements Runnable { eventSource.register(new DataChangeEventListener(this)); eventSource.open(); log.info("Connected to SSE source"); + while (running) { try { log.info("SSE state " + eventSource.isOpen()); @@ -302,4 +313,12 @@ public class PersistentEventConnection implements Runnable { log.info(name + " : " + value); } } + + public Map<String, String> getEventParaMap() { + return eventParaMap; + } + + public RestConfContext getCtx() { + return ctx; + } } |