From 56274201c51ac6a6f8c859f0b931515b50c31d0e Mon Sep 17 00:00:00 2001 From: Vijay VK Date: Fri, 6 Apr 2018 22:38:58 +0100 Subject: fix default properties Change-Id: Iae00d76ac70d6fc318d54151f99ec58eb8188aac Signed-off-by: VENKATESH KUMAR Issue-ID: DCAEGEN2-434 --- src/main/java/org/onap/dcae/commonFunction/EventProcessor.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'src/main/java/org/onap/dcae/commonFunction/EventProcessor.java') diff --git a/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java b/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java index 462287ef..d41cb23a 100644 --- a/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java +++ b/src/main/java/org/onap/dcae/commonFunction/EventProcessor.java @@ -70,13 +70,14 @@ public class EventProcessor implements Runnable { try { event = CommonStartup.fProcessingInputQueue.take(); - log.info("QueueSize:" + CommonStartup.fProcessingInputQueue.size()+ "\tEventProcessor\tRemoving element: " + event ); + // EventPublisher Ep=new EventPublisher(); while (event != null) { // As long as the producer is running we remove elements from // the queue. - + log.info("QueueSize:" + CommonStartup.fProcessingInputQueue.size()+ "\tEventProcessor\tRemoving element: " + event ); + String uuid = event.get("VESuniqueId").toString(); LoggingContext localLC = VESLogger.getLoggingContextForThread(uuid); localLC.put(EcompFields.kBeginTimestampMs, SaClock.now()); -- cgit