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 2021/04/05 08:57:06 UTC

[camel] 03/04: CAMEL-16450: camel-core - Optimize WireTap to support pooled tasks for reduced object allocations.

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 <cl...@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);
             }