File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
providers/netty/src/main/java/org/asynchttpclient/providers/netty/channel/pool Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 15
15
16
16
import static org .asynchttpclient .util .DateUtils .millisTime ;
17
17
import io .netty .channel .Channel ;
18
+ import io .netty .handler .ssl .SslHandler ;
18
19
import io .netty .util .Timeout ;
19
20
import io .netty .util .Timer ;
20
21
import io .netty .util .TimerTask ;
@@ -242,7 +243,7 @@ private ConcurrentLinkedQueue<IdleChannel> getPoolForKey(String key) {
242
243
* {@inheritDoc}
243
244
*/
244
245
public boolean offer (Channel channel , String poolKey ) {
245
- if (isClosed .get () || (!sslConnectionPoolEnabled && poolKey . startsWith ( "https" ) ))
246
+ if (isClosed .get () || (!sslConnectionPoolEnabled && channel . pipeline (). get ( SslHandler . class ) != null ))
246
247
return false ;
247
248
248
249
long now = millisTime ();
You can’t perform that action at this time.
0 commit comments