diff options
| author |   Vijay Venkatesh Kumar <vv770d@att.com> | 2018-12-27 22:08:49 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-12-27 22:08:49 +0000 |
| commit | af23ebbe4e86e75cdb44cb6014132b0eb6d515c5 (patch) | |
| tree | 4bd346e6f79711413c344832e8688bd8fbbdd0ac /src/main/java/org/onap/dcae/VesApplication.java | |
| parent | bbdc49eecebbb6fd0289db18859b5d4360ce1701 (diff) | |
| parent | f3cbb41773aac52da6c1763fb25a6e0f749229ac (diff) | |
Merge "Fix bug with processing event list"
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) { |