Update Netty version to 4.1.41.Final

Adapt to a change in Netty connection pool netty/netty#9542
reactor · Oct 24, 2019 · 4f6c954 · 4f6c954
1 parent 27956e2
commit 4f6c954
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -55,7 +55,7 @@ ext {
   assertJVersion = '3.6.1'
 
   // Libraries
-  nettyVersion = '4.1.39.Final'
+  nettyVersion = '4.1.41.Final'
   jacksonDatabindVersion = '2.5.1'
 
   // Testing

diff --git a/src/main/java/reactor/netty/resources/PooledConnectionProvider.java b/src/main/java/reactor/netty/resources/PooledConnectionProvider.java
@@ -587,7 +587,7 @@ void registerClose(Channel c, Pool pool) {
 			}
 			c.closeFuture()
 			 .addListener(ff -> {
-			     if (AttributeKey.exists("channelPool")) {
+			     if (AttributeKey.exists("channelPool." + System.identityHashCode(pool.pool))) {
 			         pool.release(c);
 			     }
 			     pool.inactiveConnections.decrementAndGet();