org.aredis.cache

Class AsyncRedisConnectionPoolManager

java.lang.Object

org.aredis.cache.AsyncRedisConnectionPoolManager

All Implemented Interfaces:

AsyncPoolMemberManager<AsyncRedisConnection>

public class AsyncRedisConnectionPoolManager
extends Object
implements AsyncPoolMemberManager<AsyncRedisConnection>

A Pool Member Manager for AsyncRedisConnection so that AsyncObjectPool can be used to create a pool of AsyncRedisConnection. This is used internally by AsyncRedisFactory to create a connection pool when requested for a redis server.

Author:

Suresh

Constructor Summary

Constructors

Constructor and Description
AsyncRedisConnectionPoolManager(AsyncSocketTransportFactory pconnectionFactory, RedisServerInfo predisServerInfo, Executor pexecutor, int pshutdownDelay) Creates a Pool Member manager with necessary information to create AsyncRedisConnection objects.
AsyncRedisConnectionPoolManager(RedisServerInfo pserverInfo, Executor pexecutor)

Method Summary

Methods

Modifier and Type	Method and Description
void	beforeReturn(AsyncRedisConnection con) Called before a member is returned back to the pool.
AsyncRedisConnection	createObject() Creates an AsyncRedisConnection.
void	destroyObject(AsyncRedisConnection con) Called when an Object is removed from the pool because the pool size is reduced due to a setPoolSize call.
void	onBorrow(AsyncRedisConnection con) Called when a borrowed member Object is handed over to the caller.

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncRedisConnectionPoolManager

public AsyncRedisConnectionPoolManager(AsyncSocketTransportFactory pconnectionFactory,
                               RedisServerInfo predisServerInfo,
                               Executor pexecutor,
                               int pshutdownDelay)

Creates a Pool Member manager with necessary information to create AsyncRedisConnection objects.

Parameters:

pconnectionFactory - Connection Factory to use to create AsyncSocketTransport

predisServerInfo - Server Info containing redis server and port

pexecutor - Executor to use in case Async Borrow is required

pshutdownDelay - Shut Down delay to use when freeing Objects

AsyncRedisConnectionPoolManager

public AsyncRedisConnectionPoolManager(RedisServerInfo pserverInfo,
                               Executor pexecutor)

Method Detail

createObject

public AsyncRedisConnection createObject()

Creates an AsyncRedisConnection.

Specified by:

createObject in interface AsyncPoolMemberManager<AsyncRedisConnection>

Returns:

New member Object

destroyObject

public void destroyObject(AsyncRedisConnection con)

Description copied from interface: AsyncPoolMemberManager

Called when an Object is removed from the pool because the pool size is reduced due to a setPoolSize call.

Specified by:

destroyObject in interface AsyncPoolMemberManager<AsyncRedisConnection>

onBorrow

public void onBorrow(AsyncRedisConnection con)

Description copied from interface: AsyncPoolMemberManager

Called when a borrowed member Object is handed over to the caller.

Specified by:

onBorrow in interface AsyncPoolMemberManager<AsyncRedisConnection>

Parameters:

con - Borrowed item

beforeReturn

public void beforeReturn(AsyncRedisConnection con)

Description copied from interface: AsyncPoolMemberManager

Called before a member is returned back to the pool.

Specified by:

beforeReturn in interface AsyncPoolMemberManager<AsyncRedisConnection>

Parameters:

con - item being returned