diff options
| author |   Bogumil Zebek <bogumil.zebek@nokia.com> | 2020-11-05 15:14:02 +0100 |
|---|---|---|
| committer | Zebek Bogumil <bogumil.zebek@nokia.com> | 2020-11-06 11:41:01 +0100 |
| commit | 266777f52144bc1e6110c18d34de612538b78b26 (patch) | |
| tree | d6a98f7adff1a81e7fd51b6c76cf0df7b4441a23 /src/main/java/org/onap/dcae/common | |
| parent | 1599617246f0ffec1b1c7840f9c7c42318183dcd (diff) | |
CBS configuration fetching
- Fix deadlock problem which occurs during starting application
Change-Id: I9103f0efd7caa105727f4814532934881335190f
Issue-ID: DCAEGEN2-2495
Signed-off-by: Zebek Bogumil <bogumil.zebek@nokia.com>
Diffstat (limited to 'src/main/java/org/onap/dcae/common')
| -rw-r--r-- | src/main/java/org/onap/dcae/common/publishing/DMaaPEventPublisher.java | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/main/java/org/onap/dcae/common/publishing/DMaaPEventPublisher.java b/src/main/java/org/onap/dcae/common/publishing/DMaaPEventPublisher.java index 876c391b..2b4cfc15 100644 --- a/src/main/java/org/onap/dcae/common/publishing/DMaaPEventPublisher.java +++ b/src/main/java/org/onap/dcae/common/publishing/DMaaPEventPublisher.java @@ -42,7 +42,7 @@ import static org.onap.dcae.common.publishing.VavrUtils.f; public class DMaaPEventPublisher { private static final int PENDING_MESSAGE_LOG_THRESHOLD = 100; private static final Logger log = LoggerFactory.getLogger(DMaaPEventPublisher.class); - private final DMaaPPublishersCache publishersCache; + private DMaaPPublishersCache publishersCache; private final Logger outputLogger = LoggerFactory.getLogger("org.onap.dcae.common.output"); DMaaPEventPublisher(DMaaPPublishersCache publishersCache) { @@ -53,6 +53,14 @@ public class DMaaPEventPublisher { this(new DMaaPPublishersCache(dMaaPConfig)); } + /** + * Reload Dmaap configuration + * @param dmaapConfiguration Dmaap configuration + */ + public void reload(Map<String, PublisherConfig> dmaapConfiguration){ + this.publishersCache = new DMaaPPublishersCache(dmaapConfiguration); + } + public void sendEvent(VesEvent vesEvent, String dmaapId){ clearVesUniqueIdFromEvent(vesEvent); publishersCache.getPublisher(dmaapId) |