[camel] 01/02: CAMEL-12435: camel-netty4 - Shared connection pool should re-create connection if its no longer valid

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git

commit ea8040a0db52b8b535ad0698f82df6bc37625b09
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Apr 12 14:10:39 2018 +0200

    CAMEL-12435: camel-netty4 - Shared connection pool should re-create 
connection if its no longer valid
---
 .../org/apache/camel/component/netty4/SharedSingletonObjectPool.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SharedSingletonObjectPool.java
 
b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SharedSingletonObjectPool.java
index b7408bb..ebfb4ef 100644
--- 
a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SharedSingletonObjectPool.java
+++ 
b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SharedSingletonObjectPool.java
@@ -20,6 +20,8 @@ import java.util.NoSuchElementException;
 
 import org.apache.commons.pool.ObjectPool;
 import org.apache.commons.pool.PoolableObjectFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * An {@link org.apache.commons.pool.ObjectPool} that uses a single shared 
instance.
@@ -29,6 +31,7 @@ import org.apache.commons.pool.PoolableObjectFactory;
  */
 public class SharedSingletonObjectPool<T> implements ObjectPool<T> {
 
+    private static final Logger LOG = 
LoggerFactory.getLogger(SharedSingletonObjectPool.class);
     private final PoolableObjectFactory<T> factory;
     private volatile T t;
 
@@ -42,6 +45,7 @@ public class SharedSingletonObjectPool<T> implements 
ObjectPool<T> {
             // ensure the object is validate before we borrow it
             if (!factory.validateObject(t)) {
                 invalidateObject(t);
+                LOG.info("Recreating new connection as current connection is 
invalid: {}", t);
                 t = null;
             }
         }

-- 
To stop receiving notification emails like this one, please contact
davscl...@apache.org.