diff options
| author |   vagrant <vv770d@att.com> | 2018-01-20 14:55:43 +0000 |
|---|---|---|
| committer | vagrant <vv770d@att.com> | 2018-01-20 14:59:57 +0000 |
| commit | 7672276206d44d8dbc17bf73ef950b17191b6257 (patch) | |
| tree | 12a3e1aad24ec7eb59294629adf677c7c62188e1 /src/main/java/org/onap/dcae/commonFunction/EventProcessor.java | |
| parent | 3b9fd0933fcda7b4f85aff70fc72ffd517e5b30f (diff) | |
Optimize collector publish mechanism
Change-Id: I6d5fb2ad45257831e8e0ff62812df1fd1401464d
Issue-ID: DCAEGEN2-281
Signed-off-by: Vijay VK <vv770d@att.com>
Diffstat (limited to 'src/main/java/org/onap/dcae/commonFunction/EventProcessor.java')
| -rw-r--r-- | src/main/java/org/onap/dcae/commonFunction/EventProcessor.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java b/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java index 79dea790..6811c672 100644 --- a/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java +++ b/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java @@ -70,7 +70,7 @@ public class EventProcessor implements Runnable { try { event = CommonStartup.fProcessingInputQueue.take(); - log.info("EventProcessor\tRemoving element: " + event); + log.info("QueueSize:" + CommonStartup.fProcessingInputQueue.size()+ "\tEventProcessor\tRemoving element: " + event ); // EventPublisher Ep=new EventPublisher(); while (event != null) { @@ -95,7 +95,8 @@ public class EventProcessor implements Runnable { for (String aStreamIdList : streamIdList) { log.info("Invoking publisher for streamId:" + aStreamIdList); this.overrideEvent(); - EventPublisher.getInstance(aStreamIdList).sendEvent(event); + //EventPublisher.getInstance(aStreamIdList).sendEvent(event); + EventPublisherHash.getInstance().sendEvent(event, aStreamIdList); } } |