org.springframework.data.gemfire.client

Class PoolFactoryBean

java.lang.Object

org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<org.apache.geode.cache.client.Pool>

org.springframework.data.gemfire.client.PoolFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<org.apache.geode.cache.client.Pool>, InitializingBean

public class PoolFactoryBean
extends AbstractFactoryBeanSupport<org.apache.geode.cache.client.Pool>
implements DisposableBean, InitializingBean

Spring FactoryBean to construct, configure and initialize a Pool. If a new Pool is created, its lifecycle is bound to that of this declaring FactoryBean and indirectly, the Spring container. If a Pool having the configured name already exists, then the existing Pool will be returned as is without any modifications and its lifecycle will be unaffected by this FactoryBean.

Author:

Costin Leau, John Blum

See Also:

InetSocketAddress, ClientCache, Pool, PoolFactory, PoolManager, DistributedSystem, DisposableBean, InitializingBean, PoolConfigurer, AbstractFactoryBeanSupport, ConnectionEndpoint, ConnectionEndpointList

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	PoolFactoryBean.PoolFactoryInitializer Callback interface to initialize the PoolFactory used by this PoolFactoryBean to create a Pool by providing additional or alternative configuration for the factory.

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_LOCATOR_PORT
protected static int	DEFAULT_SERVER_PORT

Fields inherited from class org.springframework.data.gemfire.support.AbstractFactoryBeanSupport

DEFAULT_SINGLETON

Constructor Summary

Constructors

Constructor and Description
PoolFactoryBean()

Method Summary

Modifier and Type	Method and Description
void	addLocators(ConnectionEndpoint... locators)
void	addLocators(Iterable<ConnectionEndpoint> locators)
void	addServers(ConnectionEndpoint... servers)
void	addServers(Iterable<ConnectionEndpoint> servers)
void	afterPropertiesSet() Prepares the construction, configuration and initialization of a new Pool.
protected void	applyPoolConfigurers(Iterable<PoolConfigurer> poolConfigurers) Null-safe operation to apply the given Iterable of PoolConfigurers to this PoolFactoryBean.
protected void	applyPoolConfigurers(PoolConfigurer... poolConfigurers) Null-safe operation to apply the given array of PoolConfigurers to this PoolFactoryBean.
protected org.apache.geode.cache.client.PoolFactory	configure(org.apache.geode.cache.client.PoolFactory poolFactory) Configures the given PoolFactory from this PoolFactoryBean.
protected org.apache.geode.cache.client.Pool	create(org.apache.geode.cache.client.PoolFactory poolFactory, String poolName) Creates a Pool with the given name using the provided PoolFactory.
protected org.apache.geode.cache.client.PoolFactory	createPoolFactory() Creates an instance of the PoolFactory interface to construct, configure and initialize a Pool.
void	destroy() Releases all system resources and destroys the Pool when created by this PoolFactoryBean.
protected PoolConfigurer	getCompositePoolConfigurer() Returns a reference to the Composite PoolConfigurer used to apply additional configuration to this PoolFactoryBean on Spring container initialization.
protected String	getName()
org.apache.geode.cache.client.Pool	getObject() Returns an object reference to the Pool created by this PoolFactoryBean.
Class<?>	getObjectType() Returns the type of Pool produced by this PoolFactoryBean.
org.apache.geode.cache.client.Pool	getPool()
protected org.apache.geode.cache.client.PoolFactory	initialize(org.apache.geode.cache.client.PoolFactory poolFactory) Initializes the given PoolFactory with any configured PoolFactoryBean.PoolFactoryInitializer.
protected org.apache.geode.cache.client.Pool	postProcess(org.apache.geode.cache.client.Pool pool) Post processes the Pool created by this PoolFactoryBean.
protected org.apache.geode.cache.client.PoolFactory	postProcess(org.apache.geode.cache.client.PoolFactory poolFactory) Post processes the fully configured PoolFactory.
void	setFreeConnectionTimeout(int freeConnectionTimeout)
void	setIdleTimeout(long idleTimeout)
void	setKeepAlive(boolean keepAlive)
void	setLoadConditioningInterval(int loadConditioningInterval)
void	setLocators(ConnectionEndpoint[] connectionEndpoints)
void	setLocators(Iterable<ConnectionEndpoint> connectionEndpoints)
void	setLocatorsConfiguration(Object locatorsConfiguration)
void	setMaxConnections(int maxConnections)
void	setMinConnections(int minConnections)
void	setMultiUserAuthentication(boolean multiUserAuthentication)
void	setName(String name)
void	setPingInterval(long pingInterval)
void	setPool(org.apache.geode.cache.client.Pool pool)
void	setPoolConfigurers(List<PoolConfigurer> poolConfigurers) Null-safe operation to set an Iterable of PoolConfigurers used to apply additional configuration to this PoolFactoryBean when using Annotation-based configuration.
void	setPoolConfigurers(PoolConfigurer... poolConfigurers) Null-safe operation to set an array of PoolConfigurers used to apply additional configuration to this PoolFactoryBean when using Annotation-based configuration.
void	setPoolFactoryInitializer(PoolFactoryBean.PoolFactoryInitializer poolFactoryInitializer) Sets the PoolFactoryBean.PoolFactoryInitializer to initialize the PoolFactory used by this PoolFactoryBean to create a Pool.
void	setPrSingleHopEnabled(boolean prSingleHopEnabled)
void	setReadTimeout(int readTimeout)
void	setRetryAttempts(int retryAttempts)
void	setServerGroup(String serverGroup)
void	setServers(ConnectionEndpoint[] connectionEndpoints)
void	setServers(Iterable<ConnectionEndpoint> connectionEndpoints)
void	setServersConfiguration(Object serversConfiguration)
void	setSocketBufferSize(int socketBufferSize)
void	setSocketConnectTimeout(int socketConnectTimeout)
void	setStatisticInterval(int statisticInterval)
void	setSubscriptionAckInterval(int subscriptionAckInterval)
void	setSubscriptionEnabled(boolean subscriptionEnabled)
void	setSubscriptionMessageTrackingTimeout(int subscriptionMessageTrackingTimeout)
void	setSubscriptionRedundancy(int subscriptionRedundancy)
void	setSubscriptionTimeoutMultiplier(int subscriptionTimeoutMultiplier)
void	setThreadLocalConnections(boolean threadLocalConnections)

Methods inherited from class org.springframework.data.gemfire.support.AbstractFactoryBeanSupport

getBeanClassLoader, getBeanFactory, getBeanName, getLog, isSingleton, logDebug, logDebug, logError, logError, logInfo, logInfo, logWarning, logWarning, newLog, setBeanClassLoader, setBeanFactory, setBeanName

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_LOCATOR_PORT

protected static final int DEFAULT_LOCATOR_PORT

See Also:

Constant Field Values

DEFAULT_SERVER_PORT

protected static final int DEFAULT_SERVER_PORT

See Also:

Constant Field Values

Constructor Detail

PoolFactoryBean

public PoolFactoryBean()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Prepares the construction, configuration and initialization of a new Pool.

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception - if Pool initialization fails.

See Also:

PoolManager, PoolFactory, Pool

applyPoolConfigurers

protected void applyPoolConfigurers(PoolConfigurer... poolConfigurers)

Null-safe operation to apply the given array of PoolConfigurers to this PoolFactoryBean.

Parameters:

poolConfigurers - array of PoolConfigurers applied to this PoolFactoryBean.

See Also:

PoolConfigurer, applyPoolConfigurers(Iterable)

applyPoolConfigurers

protected void applyPoolConfigurers(Iterable<PoolConfigurer> poolConfigurers)

Null-safe operation to apply the given Iterable of PoolConfigurers to this PoolFactoryBean.

Parameters:

poolConfigurers - Iterable of PoolConfigurers applied to this PoolFactoryBean.

See Also:

PoolConfigurer

destroy

public void destroy()
             throws Exception

Releases all system resources and destroys the Pool when created by this PoolFactoryBean.

Specified by:

destroy in interface DisposableBean

Throws:

Exception - if the Pool destruction caused an error.

See Also:

DisposableBean.destroy()

getObject

public org.apache.geode.cache.client.Pool getObject()
                                             throws Exception

Returns an object reference to the Pool created by this PoolFactoryBean.

Specified by:

getObject in interface FactoryBean<org.apache.geode.cache.client.Pool>

Returns:

an object reference to the Pool created by this PoolFactoryBean.

Throws:

Exception

See Also:

FactoryBean.getObject(), Pool

createPoolFactory

protected org.apache.geode.cache.client.PoolFactory createPoolFactory()

Creates an instance of the PoolFactory interface to construct, configure and initialize a Pool.

Returns:

a PoolFactory implementation to create a Pool.

See Also:

PoolManager.createFactory(), PoolFactory

configure

protected org.apache.geode.cache.client.PoolFactory configure(org.apache.geode.cache.client.PoolFactory poolFactory)

Configures the given PoolFactory from this PoolFactoryBean.

Parameters:

poolFactory - PoolFactory to configure.

Returns:

the given PoolFactory.

See Also:

PoolFactory

initialize

protected org.apache.geode.cache.client.PoolFactory initialize(org.apache.geode.cache.client.PoolFactory poolFactory)

Initializes the given PoolFactory with any configured PoolFactoryBean.PoolFactoryInitializer.

Parameters:

poolFactory - PoolFactory to initialize.

Returns:

the initialized PoolFactory.

See Also:

PoolFactory

postProcess

protected org.apache.geode.cache.client.PoolFactory postProcess(org.apache.geode.cache.client.PoolFactory poolFactory)

Post processes the fully configured PoolFactory.

Parameters:

poolFactory - PoolFactory to post process.

Returns:

the post processed PoolFactory.

See Also:

PoolFactory

create

protected org.apache.geode.cache.client.Pool create(org.apache.geode.cache.client.PoolFactory poolFactory,
                                                    String poolName)

Creates a Pool with the given name using the provided PoolFactory.

Parameters:

poolFactory - PoolFactory used to create the Pool.

poolName - name of the new Pool.

Returns:

a new instance of Pool with the given name.

See Also:

PoolFactory.create(String), Pool

postProcess

protected org.apache.geode.cache.client.Pool postProcess(org.apache.geode.cache.client.Pool pool)

Post processes the Pool created by this PoolFactoryBean.

Parameters:

pool - Pool to post process.

Returns:

the post processed Pool.

See Also:

Pool

getObjectType

public Class<?> getObjectType()

Returns the type of Pool produced by this PoolFactoryBean.

Specified by:

getObjectType in interface FactoryBean<org.apache.geode.cache.client.Pool>

Returns:

the type of Pool produced by this PoolFactoryBean.

See Also:

FactoryBean.getObjectType()

addLocators

public void addLocators(ConnectionEndpoint... locators)

addLocators

public void addLocators(Iterable<ConnectionEndpoint> locators)

addServers

public void addServers(ConnectionEndpoint... servers)

addServers

public void addServers(Iterable<ConnectionEndpoint> servers)

getCompositePoolConfigurer

protected PoolConfigurer getCompositePoolConfigurer()

Returns a reference to the Composite PoolConfigurer used to apply additional configuration to this PoolFactoryBean on Spring container initialization.

Returns:

the Composite PoolConfigurer.

See Also:

PoolConfigurer

setName

public void setName(String name)

getName

protected String getName()

setPool

public void setPool(org.apache.geode.cache.client.Pool pool)

getPool

public org.apache.geode.cache.client.Pool getPool()

setFreeConnectionTimeout

public void setFreeConnectionTimeout(int freeConnectionTimeout)

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

setKeepAlive

public void setKeepAlive(boolean keepAlive)

setLoadConditioningInterval

public void setLoadConditioningInterval(int loadConditioningInterval)

setLocators

public void setLocators(ConnectionEndpoint[] connectionEndpoints)

setLocators

public void setLocators(Iterable<ConnectionEndpoint> connectionEndpoints)

setMaxConnections

public void setMaxConnections(int maxConnections)

setMinConnections

public void setMinConnections(int minConnections)

setMultiUserAuthentication

public void setMultiUserAuthentication(boolean multiUserAuthentication)

setPingInterval

public void setPingInterval(long pingInterval)

setPoolConfigurers

public void setPoolConfigurers(PoolConfigurer... poolConfigurers)

Null-safe operation to set an array of PoolConfigurers used to apply additional configuration to this PoolFactoryBean when using Annotation-based configuration.

Parameters:

poolConfigurers - array of PoolConfigurers used to apply additional configuration to this PoolFactoryBean.

See Also:

PoolConfigurer, setPoolConfigurers(List)

setPoolConfigurers

public void setPoolConfigurers(List<PoolConfigurer> poolConfigurers)

Null-safe operation to set an Iterable of PoolConfigurers used to apply additional configuration to this PoolFactoryBean when using Annotation-based configuration.

Parameters:

poolConfigurers - Iterable of PoolConfigurers used to apply additional configuration to this PoolFactoryBean.

See Also:

PoolConfigurer

setPoolFactoryInitializer

public void setPoolFactoryInitializer(PoolFactoryBean.PoolFactoryInitializer poolFactoryInitializer)

Sets the PoolFactoryBean.PoolFactoryInitializer to initialize the PoolFactory used by this PoolFactoryBean to create a Pool.

Parameters:

poolFactoryInitializer - PoolFactoryBean.PoolFactoryInitializer user provided callback interface invoked by this PoolFactoryBean to initialize the PoolFactory constructed to create the Pool.

See Also:

PoolFactoryBean.PoolFactoryInitializer

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(ConnectionEndpoint[] connectionEndpoints)

setServers

public void setServers(Iterable<ConnectionEndpoint> connectionEndpoints)

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

setSocketConnectTimeout

public void setSocketConnectTimeout(int socketConnectTimeout)

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)

setSubscriptionTimeoutMultiplier

public void setSubscriptionTimeoutMultiplier(int subscriptionTimeoutMultiplier)

setThreadLocalConnections

public void setThreadLocalConnections(boolean threadLocalConnections)

setLocatorsConfiguration

public final void setLocatorsConfiguration(Object locatorsConfiguration)

setServersConfiguration

public final void setServersConfiguration(Object serversConfiguration)