diff options
| author |   Zlatko Murgoski <zlatko.murgoski@nokia.com> | 2018-12-19 15:00:14 +0100 |
|---|---|---|
| committer | Zlatko Murgoski <zlatko.murgoski@nokia.com> | 2018-12-21 16:42:15 +0100 |
| commit | f3cbb41773aac52da6c1763fb25a6e0f749229ac (patch) | |
| tree | eae66a433ab95c91a588fb8278bff4282b9314ce /src/main/java/org/onap/dcae/VesApplication.java | |
| parent | b95941adee2725406c194c710240a36a698a183a (diff) | |
Fix bug with processing event list
DMaapEventPublisher processing of eventList
Issue-ID: DCAEGEN2-1035
Change-Id: If62ec51d1dc1f0e501fda624dae23c7a83d3727b
Signed-off-by: Zlatko Murgoski <zlatko.murgoski@nokia.com>
Diffstat (limited to 'src/main/java/org/onap/dcae/VesApplication.java')
| -rw-r--r-- | src/main/java/org/onap/dcae/VesApplication.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/main/java/org/onap/dcae/VesApplication.java b/src/main/java/org/onap/dcae/VesApplication.java index a70d0935..b57caf3c 100644 --- a/src/main/java/org/onap/dcae/VesApplication.java +++ b/src/main/java/org/onap/dcae/VesApplication.java @@ -29,6 +29,7 @@ import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.TimeUnit; import org.json.JSONObject; import org.onap.dcae.commonFunction.EventProcessor; +import org.onap.dcae.commonFunction.EventSender; import org.onap.dcae.commonFunction.event.publishing.DMaaPConfigurationParser; import org.onap.dcae.commonFunction.event.publishing.EventPublisher; import org.onap.dcae.commonFunction.event.publishing.PublisherConfig; @@ -66,7 +67,8 @@ public class VesApplication { .parseToDomainMapping(Paths.get(properties.dMaaPConfigurationFileLocation())) .get()); spawnDynamicConfigUpdateThread(publisher, properties); - EventProcessor ep = new EventProcessor(EventPublisher.createPublisher(oplog, getDmapConfig()), properties); + EventProcessor ep = new EventProcessor( + new EventSender(EventPublisher.createPublisher(oplog, getDmapConfig()), properties)); ExecutorService executor = Executors.newFixedThreadPool(MAX_THREADS); for (int i = 0; i < MAX_THREADS; ++i) { |