org.springframework.data.gemfire.client

Class PoolFactoryBean

java.lang.Object

org.springframework.data.gemfire.client.PoolFactoryBean

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<com.gemstone.gemfire.cache.client.Pool>, InitializingBean

public class PoolFactoryBean
extends Object
implements FactoryBean<com.gemstone.gemfire.cache.client.Pool>, InitializingBean, DisposableBean, BeanNameAware, BeanFactoryAware

FactoryBean for easy declaration and configuration of a GemFire Pool. If a new Pool is created, its lifecycle is bound to that of the declaring container. Note, if the Pool already exists, the existing Pool will be returned as is without any modifications and its lifecycle will be unaffected by this factory.

See Also:

Pool, PoolFactory, PoolManager

Constructor Summary

Constructors

Constructor and Description
PoolFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected com.gemstone.gemfire.cache.client.PoolFactory	createPoolFactory()
void	destroy()
com.gemstone.gemfire.cache.client.Pool	getObject()
Class<?>	getObjectType()
boolean	isSingleton()
void	setBeanFactory(BeanFactory beanFactory)
void	setBeanName(String name)
void	setFreeConnectionTimeout(int freeConnectionTimeout)
void	setIdleTimeout(long idleTimeout)
void	setKeepAlive(boolean keepAlive)
void	setLoadConditioningInterval(int loadConditioningInterval)
void	setLocators(Collection<InetSocketAddress> locators)
void	setMaxConnections(int maxConnections)
void	setMinConnections(int minConnections)
void	setMultiUserAuthentication(boolean multiUserAuthentication)
void	setName(String name)
void	setPingInterval(long pingInterval)
void	setPool(com.gemstone.gemfire.cache.client.Pool pool)
void	setPrSingleHopEnabled(boolean prSingleHopEnabled)
void	setReadTimeout(int readTimeout)
void	setRetryAttempts(int retryAttempts)
void	setServerGroup(String serverGroup)
void	setServers(Collection<InetSocketAddress> servers)
void	setSocketBufferSize(int socketBufferSize)
void	setStatisticInterval(int statisticInterval)
void	setSubscriptionAckInterval(int subscriptionAckInterval)
void	setSubscriptionEnabled(boolean subscriptionEnabled)
void	setSubscriptionMessageTrackingTimeout(int subscriptionMessageTrackingTimeout)
void	setSubscriptionRedundancy(int subscriptionRedundancy)
void	setThreadLocalConnections(boolean threadLocalConnections)

Methods inherited from class java.lang.Object

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

Constructor Detail

PoolFactoryBean

public PoolFactoryBean()

Method Detail

getObject

public com.gemstone.gemfire.cache.client.Pool getObject()
                                                 throws Exception

Specified by:

getObject in interface FactoryBean<com.gemstone.gemfire.cache.client.Pool>

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<com.gemstone.gemfire.cache.client.Pool>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface FactoryBean<com.gemstone.gemfire.cache.client.Pool>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

createPoolFactory

protected com.gemstone.gemfire.cache.client.PoolFactory createPoolFactory()

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

Specified by:

setBeanFactory in interface BeanFactoryAware

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

setName

public void setName(String name)

Parameters:

name - the name to set

setPool

public void setPool(com.gemstone.gemfire.cache.client.Pool pool)

Parameters:

pool - the pool to set

setFreeConnectionTimeout

public void setFreeConnectionTimeout(int freeConnectionTimeout)

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

setKeepAlive

public void setKeepAlive(boolean keepAlive)

setLocators

public void setLocators(Collection<InetSocketAddress> locators)

setLoadConditioningInterval

public void setLoadConditioningInterval(int loadConditioningInterval)

setMaxConnections

public void setMaxConnections(int maxConnections)

setMinConnections

public void setMinConnections(int minConnections)

setMultiUserAuthentication

public void setMultiUserAuthentication(boolean multiUserAuthentication)

setPingInterval

public void setPingInterval(long pingInterval)

setPrSingleHopEnabled

public void setPrSingleHopEnabled(boolean prSingleHopEnabled)

setReadTimeout

public void setReadTimeout(int readTimeout)

setRetryAttempts

public void setRetryAttempts(int retryAttempts)

setServerGroup

public void setServerGroup(String serverGroup)

setServers

public void setServers(Collection<InetSocketAddress> servers)

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

setStatisticInterval

public void setStatisticInterval(int statisticInterval)

setSubscriptionAckInterval

public void setSubscriptionAckInterval(int subscriptionAckInterval)

setSubscriptionEnabled

public void setSubscriptionEnabled(boolean subscriptionEnabled)

setSubscriptionMessageTrackingTimeout

public void setSubscriptionMessageTrackingTimeout(int subscriptionMessageTrackingTimeout)

setSubscriptionRedundancy

public void setSubscriptionRedundancy(int subscriptionRedundancy)

setThreadLocalConnections

public void setThreadLocalConnections(boolean threadLocalConnections)