[camel] 05/05: CAMEL-16451: camel-core - ExchangePooling for EIPs. Wiretap EIP

[davsclaus]

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 ab47d9bc40139d57aa8de833d01075d63b8d13d6
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Apr 5 18:35:43 2021 +0200

    CAMEL-16451: camel-core - ExchangePooling for EIPs. Wiretap EIP
---
 .../org/apache/camel/impl/engine/PooledProcessorExchangeFactory.java    | 2 +-
 .../org/apache/camel/support/DefaultEndpointUtilizationStatistics.java  | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledProcessorExchangeFactory.java
 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledProcessorExchangeFactory.java
index 697e02f..ab86b3d 100644
--- 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledProcessorExchangeFactory.java
+++ 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledProcessorExchangeFactory.java
@@ -96,7 +96,7 @@ public class PooledProcessorExchangeFactory extends 
PrototypeProcessorExchangeFa
         Exchange answer = pool.poll();
         if (answer == null) {
             // create a new exchange as there was no free from the pool
-            answer = super.create(fromEndpoint, exchangePattern);
+            answer = new DefaultPooledExchange(fromEndpoint, exchangePattern);
             if (statisticsEnabled) {
                 statistics.created.increment();
             }
diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
index ae024ec..6f83953 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
@@ -18,7 +18,6 @@ package org.apache.camel.support;
 
 import java.util.Collections;
 import java.util.Map;
-import java.util.concurrent.ConcurrentMap;
 
 import org.apache.camel.spi.EndpointUtilizationStatistics;