Package org.springframework.data.gemfire.client

Class PoolFactoryBean

java.lang.Object

org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<Pool>

org.springframework.data.gemfire.client.PoolFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<Pool>, InitializingBean

public class PoolFactoryBean
extends AbstractFactoryBeanSupport<Pool>
implements DisposableBean, InitializingBean

Spring FactoryBean used 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
• PoolResolver
• PoolConfigurer
• AbstractFactoryBeanSupport
• ConnectionEndpoint
• ConnectionEndpointList

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
protected static final int	DEFAULT_LOCATOR_PORT
protected static final PoolResolver	DEFAULT_POOL_RESOLVER
protected static final int	DEFAULT_SERVER_PORT

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

DEFAULT_SINGLETON

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
PoolFactoryBean()

Method Summary

Modifier and Type	Method	Description
void	addLocators(Iterable<ConnectionEndpoint> locators)
void	addLocators(ConnectionEndpoint... locators)
void	addServers(Iterable<ConnectionEndpoint> servers)
void	addServers(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 PoolFactory	configure(PoolFactory poolFactory)	Configures the given PoolFactory from this PoolFactoryBean.
protected Pool	create(PoolFactory poolFactory, String poolName)	Deprecated. Use createPool(PoolFactory, String) instead.
protected Pool	createPool(PoolFactory poolFactory, String poolName)	Creates a Pool with the given name using the provided PoolFactory.
protected 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()	Gets the configured name of the Pool bean.
Pool	getObject()	Returns an object reference to the Pool created by this PoolFactoryBean.
Class<?>	getObjectType()	Returns the type of Pool produced by this PoolFactoryBean.
Pool	getPool()	Gets the Pool configured and built by this PoolFactoryBean.
PoolResolver	getPoolResolver()	Returns the configured PoolResolver used to resolve Pool object by name.
protected SocketFactory	getSocketFactory()
protected PoolFactory	initialize(PoolFactory poolFactory)	Initializes the given PoolFactory with any configured PoolFactoryBean.PoolFactoryInitializer.
protected Pool	postProcess(Pool pool)	Post processes the Pool created by this PoolFactoryBean.
protected PoolFactory	postProcess(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(Iterable<ConnectionEndpoint> locators)
void	setLocators(ConnectionEndpoint[] locators)
void	setMaxConnections(int maxConnections)
void	setMinConnections(int minConnections)
void	setMultiUserAuthentication(boolean multiUserAuthentication)
void	setName(String name)	Configures the name of the Pool bean.
void	setPingInterval(long pingInterval)
void	setPool(Pool pool)	Configures the Pool to be returned by this PoolFactoryBean.
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	setPoolResolver(PoolResolver poolResolver)	Configures the PoolResolver to resolve Pool objects by name from the Apache Geode cache.
void	setPrSingleHopEnabled(boolean prSingleHopEnabled)
void	setReadTimeout(int readTimeout)
void	setRetryAttempts(int retryAttempts)
void	setServerConnectionTimeout(int serverConnectionTimeout)
void	setServerGroup(String serverGroup)
void	setServers(Iterable<ConnectionEndpoint> servers)
void	setServers(ConnectionEndpoint[] servers)
void	setSocketBufferSize(int socketBufferSize)
void	setSocketConnectTimeout(int socketConnectTimeout)
void	setSocketFactory(SocketFactory socketFactory)
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)	Deprecated.
void	setXmlDeclaredLocators(ConnectionEndpointList xmlDeclaredLocators)
void	setXmlDeclaredServers(ConnectionEndpointList xmlDeclaredServers)

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

getBeanClassLoader, getBeanFactory, getBeanName, getLogger, getOptionalLogger, isDebugLoggingEnabled, isErrorLoggingEnabled, isInfoLoggingEnabled, isSingleton, isWarnLoggingEnabled, logDebug, logDebug, logError, logError, logInfo, logInfo, logWarning, logWarning, newLogger, setBeanClassLoader, setBeanFactory, setBeanName

Methods inherited from class java.lang.Object

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

Field Details

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

DEFAULT_POOL_RESOLVER

protected static final PoolResolver DEFAULT_POOL_RESOLVER

Constructor Details

PoolFactoryBean

public PoolFactoryBean()

Method Details

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()

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

Specified by:

destroy in interface DisposableBean

See Also:

• DisposableBean.destroy()

getObject

public Pool getObject()
               throws Exception

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

Specified by:

getObject in interface FactoryBean<Pool>

Returns:

an object reference to the Pool created by this PoolFactoryBean.

Throws:

Exception

See Also:

• FactoryBean.getObject()
• Pool

createPoolFactory

protected 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 PoolFactory configure(PoolFactory poolFactory)

Configures the given PoolFactory from this PoolFactoryBean.

Parameters:

poolFactory - PoolFactory to configure.

Returns:

the given PoolFactory.

See Also:

• PoolFactory

initialize

protected PoolFactory initialize(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 PoolFactory postProcess(PoolFactory poolFactory)

Post processes the fully configured PoolFactory.

Parameters:

poolFactory - PoolFactory to post process.

Returns:

the post processed PoolFactory.

See Also:

• PoolFactory

create

@Deprecated
protected Pool create(PoolFactory poolFactory,
 String poolName)

Deprecated.

Use createPool(PoolFactory, String) instead.

createPool

protected Pool createPool(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 Pool postProcess(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<Pool>

Returns:

the type of Pool produced by this PoolFactoryBean.

See Also:

• FactoryBean.getObjectType()
• Pool
• Class

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)

Configures the name of the Pool bean.

Parameters:

name - String containing the name for the Pool bean.

See Also:

• getName()

getName

protected String getName()

Gets the configured name of the Pool bean.

Returns:

the configured name of the Pool bean.

See Also:

• AbstractFactoryBeanSupport.getBeanName()
• setName(String)

setPool

public void setPool(@Nullable
 Pool pool)

Configures the Pool to be returned by this PoolFactoryBean.

Parameters:

pool - the Pool to be returned by this PoolFactoryBean.

See Also:

• Pool

getPool

@NonNull
public Pool getPool()

Gets the Pool configured and built by this PoolFactoryBean. May return a proxy Pool if the actual Pool has not yet been configured and built by this PoolFactoryBean. In this case, the proxy Pool object will have the same configuration as the final Pool built by this PoolFactoryBean.

Returns:

the Pool configured and built by this PoolFactoryBean.

See Also:

• Pool
• setPool(Pool)

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[] locators)

setLocators

public void setLocators(Iterable<ConnectionEndpoint> locators)

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

setPoolResolver

public void setPoolResolver(PoolResolver poolResolver)

Configures the PoolResolver to resolve Pool objects by name from the Apache Geode cache.

Parameters:

poolResolver - the configured PoolResolver used to resolve Pool objects by name.

See Also:

• PoolResolver

getPoolResolver

public PoolResolver getPoolResolver()

Returns the configured PoolResolver used to resolve Pool object by name.

Returns:

the configured PoolResolver.

See Also:

• PoolResolver

setPrSingleHopEnabled

public void setPrSingleHopEnabled(boolean prSingleHopEnabled)

setReadTimeout

public void setReadTimeout(int readTimeout)

setRetryAttempts

public void setRetryAttempts(int retryAttempts)

setServerConnectionTimeout

public void setServerConnectionTimeout(int serverConnectionTimeout)

setServerGroup

public void setServerGroup(String serverGroup)

setServers

public void setServers(ConnectionEndpoint[] servers)

setServers

public void setServers(Iterable<ConnectionEndpoint> servers)

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

setSocketConnectTimeout

public void setSocketConnectTimeout(int socketConnectTimeout)

setSocketFactory

public void setSocketFactory(SocketFactory socketFactory)

getSocketFactory

protected SocketFactory getSocketFactory()

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

@Deprecated
public void setThreadLocalConnections(boolean threadLocalConnections)

Deprecated.

setXmlDeclaredLocators

public void setXmlDeclaredLocators(ConnectionEndpointList xmlDeclaredLocators)

setXmlDeclaredServers

public void setXmlDeclaredServers(ConnectionEndpointList xmlDeclaredServers)