diff options
| author |   Lusheng Ji <lji@research.att.com> | 2018-04-10 12:53:23 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-04-10 12:53:23 +0000 |
| commit | 88d7666478e5e98e24ef32637a7580c9809f9458 (patch) | |
| tree | f94c8716c5165c1120d17ae144ab09c3a40a8e05 /src/main/java | |
| parent | a0ded132d71bb489e272d50e931c4a50b448c6a9 (diff) | |
| parent | 56274201c51ac6a6f8c859f0b931515b50c31d0e (diff) | |
Merge "fix default properties"
Diffstat (limited to 'src/main/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 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());
|