Package org.xbib.netty.http.client.pool

Class BoundedChannelPool<K extends PoolKey>

java.lang.Object

org.xbib.netty.http.client.pool.BoundedChannelPool<K>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Pool<io.netty.channel.Channel>

public class BoundedChannelPool<K extends PoolKey>
extends java.lang.Object
implements Pool<io.netty.channel.Channel>

Constructor Summary

Constructors

Constructor and Description
BoundedChannelPool(java.util.concurrent.Semaphore semaphore, io.netty.handler.codec.http.HttpVersion httpVersion, boolean isSecure, java.util.List<K> nodes, io.netty.bootstrap.Bootstrap bootstrap, io.netty.channel.pool.ChannelPoolHandler channelPoolHandler, int retriesPerNode)

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	acquire()
int	acquire(java.util.List<io.netty.channel.Channel> channels, int maxCount)
void	close()
io.netty.util.AttributeKey<K>	getAttributeKey()
io.netty.handler.codec.http.HttpVersion	getVersion()
boolean	isSecure()
void	prepare(int channelCount)
void	release(io.netty.channel.Channel channel)
void	release(java.util.List<io.netty.channel.Channel> channels)

Methods inherited from class java.lang.Object

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

Constructor Detail

BoundedChannelPool

public BoundedChannelPool(java.util.concurrent.Semaphore semaphore,
                          io.netty.handler.codec.http.HttpVersion httpVersion,
                          boolean isSecure,
                          java.util.List<K> nodes,
                          io.netty.bootstrap.Bootstrap bootstrap,
                          io.netty.channel.pool.ChannelPoolHandler channelPoolHandler,
                          int retriesPerNode)

Parameters:

semaphore - the concurrency level

httpVersion - the HTTP version of the pool connections

isSecure - if this pool has secure connections

nodes - the endpoint nodes, any element may contain the port (followed after ":") to override the defaultPort argument

bootstrap - bootstrap instance

channelPoolHandler - channel pool handler being notified upon new connection is created

retriesPerNode - the max count of the subsequent connection failures to the node before the node will be excluded from the pool. If set to 0, the value is ignored.

Method Detail

getVersion

public io.netty.handler.codec.http.HttpVersion getVersion()

isSecure

public boolean isSecure()

getAttributeKey

public io.netty.util.AttributeKey<K> getAttributeKey()

prepare

public void prepare(int channelCount)
             throws java.net.ConnectException

Specified by:

prepare in interface Pool<io.netty.channel.Channel>

Throws:

java.net.ConnectException

acquire

public io.netty.channel.Channel acquire()
                                 throws java.lang.Exception

Specified by:

acquire in interface Pool<io.netty.channel.Channel>

Throws:

java.lang.Exception

acquire

public int acquire(java.util.List<io.netty.channel.Channel> channels,
                   int maxCount)
            throws java.lang.Exception

Specified by:

acquire in interface Pool<io.netty.channel.Channel>

Throws:

java.lang.Exception

release

public void release(io.netty.channel.Channel channel)
             throws java.lang.Exception

Specified by:

release in interface Pool<io.netty.channel.Channel>

Throws:

java.lang.Exception

release

public void release(java.util.List<io.netty.channel.Channel> channels)
             throws java.lang.Exception

Specified by:

release in interface Pool<io.netty.channel.Channel>

Throws:

java.lang.Exception

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable