NettyConnectorProvider (jersey-netty-connector) is throwing an exception with inactive_pooled_connection_handler error
Signed-off-by: Jorge Bescos Gascon <jorge.bescos.gascon@oracle.com>
diff --git a/connectors/netty-connector/src/main/java/org/glassfish/jersey/netty/connector/NettyConnector.java b/connectors/netty-connector/src/main/java/org/glassfish/jersey/netty/connector/NettyConnector.java
index f941e66..056ef31 100644
--- a/connectors/netty-connector/src/main/java/org/glassfish/jersey/netty/connector/NettyConnector.java
+++ b/connectors/netty-connector/src/main/java/org/glassfish/jersey/netty/connector/NettyConnector.java
@@ -24,6 +24,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.NoSuchElementException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CompletionException;
import java.util.concurrent.ExecutorService;
@@ -102,7 +103,7 @@
private final Integer maxPoolSizeTotal; //either from Jersey config, or default
private final Integer maxPoolIdle; // either from Jersey config, or default
- private static final String INACTIVE_POOLED_CONNECTION_HANDLER = "inactive_pooled_connection_handler";
+ static final String INACTIVE_POOLED_CONNECTION_HANDLER = "inactive_pooled_connection_handler";
private static final String PRUNE_INACTIVE_POOL = "prune_inactive_pool";
private static final String READ_TIMEOUT_HANDLER = "read_timeout_handler";
private static final String REQUEST_HANDLER = "request_handler";
@@ -190,10 +191,18 @@
synchronized (conns) {
while (chan == null && !conns.isEmpty()) {
chan = conns.remove(conns.size() - 1);
- chan.pipeline().remove(INACTIVE_POOLED_CONNECTION_HANDLER);
- chan.pipeline().remove(PRUNE_INACTIVE_POOL);
+ try {
+ chan.pipeline().remove(INACTIVE_POOLED_CONNECTION_HANDLER);
+ chan.pipeline().remove(PRUNE_INACTIVE_POOL);
+ } catch (NoSuchElementException e) {
+ /*
+ * Eat it.
+ * It could happen that the channel was closed, pipeline cleared and
+ * then it will fail to remove the names with this exception.
+ */
+ }
if (!chan.isOpen()) {
- chan = null;
+ chan = null;
}
}
}
