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();
}