com.shulie.druid.pool.ha.node

类 PoolUpdater

java.lang.Object

com.shulie.druid.pool.ha.node.PoolUpdater

所有已实现的接口:

Observer

public class PoolUpdater
extends Object
implements Observer

Update the DataSource Connection Pool when notified.

作者:

DigitalSonic

字段概要

字段

限定符和类型	字段和说明
static int	DEFAULT_INTERVAL

构造器概要

构造器

构造器和说明
PoolUpdater(HighAvailableDataSource highAvailableDataSource)

方法概要

限定符和类型	方法和说明
protected void	addNode(NodeEvent event)
protected void	deleteNode(NodeEvent event)
void	destroy()
HighAvailableDataSource	getHighAvailableDataSource()
int	getIntervalSeconds()
Set<String>	getNodesToDel()
void	init() Create a ScheduledExecutorService to remove unused DataSources.
boolean	isAllowEmptyPool()
void	removeDataSources() Remove unused DataSources.
void	setAllowEmptyPool(boolean allowEmptyPool)
void	setHighAvailableDataSource(HighAvailableDataSource highAvailableDataSource)
void	setIntervalSeconds(int intervalSeconds)
void	update(Observable o, Object arg) Process the given NodeEvent[].

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_INTERVAL

public static final int DEFAULT_INTERVAL

另请参阅:

常量字段值

构造器详细资料

PoolUpdater

public PoolUpdater(HighAvailableDataSource highAvailableDataSource)

方法详细资料

init

public void init()

Create a ScheduledExecutorService to remove unused DataSources.

destroy

public void destroy()

update

public void update(Observable o,
                   Object arg)

Process the given NodeEvent[]. Maybe add / delete some nodes.

指定者:

update 在接口中 Observer

removeDataSources

public void removeDataSources()

Remove unused DataSources.

addNode

protected void addNode(NodeEvent event)

deleteNode

protected void deleteNode(NodeEvent event)

getHighAvailableDataSource

public HighAvailableDataSource getHighAvailableDataSource()

setHighAvailableDataSource

public void setHighAvailableDataSource(HighAvailableDataSource highAvailableDataSource)

getNodesToDel

public Set<String> getNodesToDel()

getIntervalSeconds

public int getIntervalSeconds()

setIntervalSeconds

public void setIntervalSeconds(int intervalSeconds)

isAllowEmptyPool

public boolean isAllowEmptyPool()

setAllowEmptyPool

public void setAllowEmptyPool(boolean allowEmptyPool)