You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2020/01/13 16:39:37 UTC
[camel] 03/03: CAMEL-14354: camel-core - Optimize
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 <cl...@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) {