summaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorVijay VK <vv770d@att.com>2018-04-06 22:38:58 +0100
committerVENKATESH KUMAR <vv770d@att.com>2018-04-07 00:49:31 -0400
commit56274201c51ac6a6f8c859f0b931515b50c31d0e (patch)
treef94c8716c5165c1120d17ae144ab09c3a40a8e05 /src/main/java
parent60367be29283c81f5b977e71c9d06e34f565f840 (diff)
fix default properties
Change-Id: Iae00d76ac70d6fc318d54151f99ec58eb8188aac Signed-off-by: VENKATESH KUMAR <vv770d@att.com> Issue-ID: DCAEGEN2-434
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/org/onap/dcae/commonFunction/EventProcessor.java5
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 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());