com.lambdaworks.redis

Class RedisConnectionPool<T>

java.lang.Object

com.lambdaworks.redis.RedisConnectionPool<T>

Type Parameters:

T - Connection type.

All Implemented Interfaces:

Closeable, AutoCloseable

public class RedisConnectionPool<T>
extends Object
implements Closeable

Connection pool for redis connections.

Since:

3.0

Author:

Mark Paluch

Constructor Summary

Constructors

Constructor and Description
RedisConnectionPool(com.lambdaworks.redis.RedisConnectionProvider<T> redisConnectionProvider, int maxActive, int maxIdle, long maxWait) Create a new connection pool

Method Summary

Modifier and Type	Method and Description
void	addListener(CloseEvents.CloseListener listener) Adds a CloseListener.
T	allocateConnection() Allocate a connection from the pool.
void	close() Close the pool and close all idle connections.
void	freeConnection(T t) Return a connection into the pool.
Class<? extends T>	getComponentType()
int	getNumActive()
int	getNumIdle()
void	removeListener(CloseEvents.CloseListener listener) Removes a CloseListener.

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisConnectionPool

public RedisConnectionPool(com.lambdaworks.redis.RedisConnectionProvider<T> redisConnectionProvider,
                           int maxActive,
                           int maxIdle,
                           long maxWait)

Create a new connection pool

Parameters:

redisConnectionProvider - the connection provider

maxActive - max active connections

maxIdle - max idle connections

maxWait - max wait time (ms) for a connection

Method Detail

allocateConnection

public T allocateConnection()

Allocate a connection from the pool. It must be returned using freeConnection (or alternatively call close() on the connection).

Returns:

a pooled connection.

freeConnection

public void freeConnection(T t)

Return a connection into the pool.

Parameters:

t - the connection.

getNumIdle

public int getNumIdle()

Returns:

the number of idle connections

getNumActive

public int getNumActive()

Returns:

the number of active connections.

close

public void close()

Close the pool and close all idle connections. Active connections won't be closed.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getComponentType

public Class<? extends T> getComponentType()

Returns:

the component type (pool resource type).

addListener

public void addListener(CloseEvents.CloseListener listener)

Adds a CloseListener.

Parameters:

listener - the listener

removeListener

public void removeListener(CloseEvents.CloseListener listener)

Removes a CloseListener.

Parameters:

listener - the listener