This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit cc8b2861b1de05ba61f88d8258b04ebf852c25d3
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Jan 13 17:33:36 2020 +0100

    CAMEL-14354: camel-core - Optimize
---
 .../org/apache/camel/support/processor/CamelLogProcessor.java     | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/processor/CamelLogProcessor.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/processor/CamelLogProcessor.java
index 064b505..1656688 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/processor/CamelLogProcessor.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/processor/CamelLogProcessor.java
@@ -44,7 +44,7 @@ public class CamelLogProcessor extends AsyncProcessorSupport 
implements IdAware,
     private CamelLogger logger;
     private ExchangeFormatter formatter;
     private MaskingFormatter maskingFormatter;
-    private Set<LogListener> listeners;
+    private final Set<LogListener> listeners;
 
     public CamelLogProcessor() {
         this(new CamelLogger(CamelLogProcessor.class.getName()));
@@ -53,10 +53,12 @@ public class CamelLogProcessor extends 
AsyncProcessorSupport implements IdAware,
     public CamelLogProcessor(CamelLogger logger) {
         this.formatter = new ToStringExchangeFormatter();
         this.logger = logger;
+        this.listeners = null;
     }
 
     public CamelLogProcessor(CamelLogger logger, ExchangeFormatter formatter, 
MaskingFormatter maskingFormatter, Set<LogListener> listeners) {
-        this(logger);
+        this.formatter = new ToStringExchangeFormatter();
+        this.logger = logger;
         this.formatter = formatter;
         this.maskingFormatter = maskingFormatter;
         this.listeners = listeners;
@@ -124,7 +126,7 @@ public class CamelLogProcessor extends 
AsyncProcessorSupport implements IdAware,
     }
 
     private String fireListeners(Exchange exchange, String message) {
-        if (listeners == null) {
+        if (listeners == null || listeners.isEmpty()) {
             return message;
         }
         for (LogListener listener : listeners) {

Reply via email to