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 8d8db66ed5fe662a6428e8f1af91363c71f73be2 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Mon Apr 5 10:55:15 2021 +0200 CAMEL-16450: camel-core - Optimize WireTap to support pooled tasks for reduced object allocations. --- .../src/main/java/org/apache/camel/processor/WireTapProcessor.java | 7 ------- 1 file changed, 7 deletions(-) diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java index 98017f6..b6c7822 100644 --- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java +++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java @@ -47,7 +47,6 @@ import org.apache.camel.support.DefaultExchange; import org.apache.camel.support.ExchangeHelper; import org.apache.camel.support.service.ServiceHelper; import org.apache.camel.util.ObjectHelper; -import org.apache.camel.util.URISupport; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -100,12 +99,6 @@ public class WireTapProcessor extends AsyncProcessorSupport private final AsyncCallback callback = new AsyncCallback() { @Override public void done(boolean doneSync) { - if (exchange.getException() != null) { - String u = URISupport.sanitizeUri(uri); - LOG.warn("Error occurred during processing " + exchange + " wiretap to " + u - + ". This exception will be ignored.", - exchange.getException()); - } taskCount.decrement(); taskFactory.release(WireTapTask.this); }