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/12 19:17:37 UTC

[camel] branch master updated: CAMEL-16222: camel-core - Fix pooled exchange factory when creating pooled exchange in auto release mode

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


The following commit(s) were added to refs/heads/master by this push:
     new b874d59  CAMEL-16222: camel-core - Fix pooled exchange factory when creating pooled exchange in auto release mode
b874d59 is described below

commit b874d59cdba67a3657a0617506fab46280ea0bcc
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Apr 12 21:13:39 2021 +0200

    CAMEL-16222: camel-core - Fix pooled exchange factory when creating pooled exchange in auto release mode
---
 .../main/java/org/apache/camel/impl/engine/PooledExchangeFactory.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledExchangeFactory.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledExchangeFactory.java
index 99289e3..1f99956 100644
--- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledExchangeFactory.java
+++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledExchangeFactory.java
@@ -87,7 +87,7 @@ public final class PooledExchangeFactory extends PrototypeExchangeFactory {
         Exchange exchange = pool.poll();
         if (exchange == null) {
             // create a new exchange as there was no free from the pool
-            exchange = new DefaultPooledExchange(fromEndpoint);
+            exchange = createPooledExchange(fromEndpoint, autoRelease);
             if (statisticsEnabled) {
                 statistics.created.increment();
             }