software.amazon.awssdk.http.nio.netty.internal.http2

Class HttpOrHttp2ChannelPool

java.lang.Object

software.amazon.awssdk.http.nio.netty.internal.http2.HttpOrHttp2ChannelPool

All Implemented Interfaces:

io.netty.channel.pool.ChannelPool, Closeable, AutoCloseable

public class HttpOrHttp2ChannelPool
extends Object
implements io.netty.channel.pool.ChannelPool

Channel pool that establishes an initial connection to determine protocol. Delegates to appropriate channel pool implementation depending on the protocol. This assumes that all connections will be negotiated with the same protocol.

Constructor Summary

Constructors

Constructor and Description
HttpOrHttp2ChannelPool(io.netty.channel.pool.ChannelPool delegatePool, io.netty.channel.EventLoopGroup group, int maxConcurrency, NettyConfiguration configuration)

Method Summary

Modifier and Type	Method and Description
io.netty.util.concurrent.Future<io.netty.channel.Channel>	acquire()
io.netty.util.concurrent.Future<io.netty.channel.Channel>	acquire(io.netty.util.concurrent.Promise<io.netty.channel.Channel> promise)
void	close()
io.netty.util.concurrent.Future<Void>	release(io.netty.channel.Channel channel)
io.netty.util.concurrent.Future<Void>	release(io.netty.channel.Channel channel, io.netty.util.concurrent.Promise<Void> promise)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpOrHttp2ChannelPool

public HttpOrHttp2ChannelPool(io.netty.channel.pool.ChannelPool delegatePool,
                              io.netty.channel.EventLoopGroup group,
                              int maxConcurrency,
                              NettyConfiguration configuration)

Method Detail

acquire

public io.netty.util.concurrent.Future<io.netty.channel.Channel> acquire()

Specified by:

acquire in interface io.netty.channel.pool.ChannelPool

acquire

public io.netty.util.concurrent.Future<io.netty.channel.Channel> acquire(io.netty.util.concurrent.Promise<io.netty.channel.Channel> promise)

Specified by:

acquire in interface io.netty.channel.pool.ChannelPool

release

public io.netty.util.concurrent.Future<Void> release(io.netty.channel.Channel channel)

Specified by:

release in interface io.netty.channel.pool.ChannelPool

release

public io.netty.util.concurrent.Future<Void> release(io.netty.channel.Channel channel,
                                                     io.netty.util.concurrent.Promise<Void> promise)

Specified by:

release in interface io.netty.channel.pool.ChannelPool

close

public void close()

Specified by:

close in interface io.netty.channel.pool.ChannelPool

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable