public class PoolFactoryBean extends Object implements org.springframework.beans.factory.FactoryBean<com.gemstone.gemfire.cache.client.Pool>, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.BeanFactoryAware
Pool
. If a new Pool
is created,
its lifecycle is bound to that of this declaring factory.
Note, 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 factory.InetSocketAddress
,
BeanNameAware
,
DisposableBean
,
FactoryBean
,
InitializingBean
,
ConnectionEndpoint
,
ConnectionEndpointList
,
Pool
,
PoolFactory
,
PoolManager
Modifier and Type | Field and Description |
---|---|
protected static int |
DEFAULT_LOCATOR_PORT |
protected static int |
DEFAULT_SERVER_PORT |
Constructor and Description |
---|
PoolFactoryBean() |
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()
Constructs and initializes a GemFire
Pool . |
protected com.gemstone.gemfire.cache.client.PoolFactory |
createPoolFactory()
=======
>>>>>>> 77482dd...
|
void |
destroy()
Destroys the GemFire
Pool if created by this PoolFactoryBean and releases all system resources
used by the Pool . |
protected org.springframework.beans.factory.BeanFactory |
getBeanFactory() |
com.gemstone.gemfire.cache.client.Pool |
getObject() |
Class<?> |
getObjectType() |
com.gemstone.gemfire.cache.client.Pool |
getPool() |
boolean |
isSingleton() |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setBeanName(String name) |
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(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(ConnectionEndpoint[] connectionEndpoints) |
void |
setServers(Iterable<ConnectionEndpoint> connectionEndpoints) |
void |
setServersConfiguration(Object serversConfiguration) |
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) |
protected static final int DEFAULT_LOCATOR_PORT
protected static final int DEFAULT_SERVER_PORT
public void afterPropertiesSet() throws Exception
Pool
.afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
Exception
- if the Pool
creation and initialization fails.Pool
,
PoolFactory
,
PoolManager
,
createPoolFactory()
public void destroy() throws Exception
Pool
if created by this PoolFactoryBean
and releases all system resources
used by the Pool
.destroy
in interface org.springframework.beans.factory.DisposableBean
Exception
- if the Pool
destruction caused an error.DisposableBean.destroy()
public com.gemstone.gemfire.cache.client.Pool getObject() throws Exception
getObject
in interface org.springframework.beans.factory.FactoryBean<com.gemstone.gemfire.cache.client.Pool>
Exception
protected com.gemstone.gemfire.cache.client.PoolFactory createPoolFactory()
PoolFactory
interface to construct, configure and initialize
a GemFire Pool
.PoolFactory
implementation to create a Pool
.PoolManager.createFactory()
,
PoolFactory
public Class<?> getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean<com.gemstone.gemfire.cache.client.Pool>
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean<com.gemstone.gemfire.cache.client.Pool>
public void addLocators(ConnectionEndpoint... locators)
public void addLocators(Iterable<ConnectionEndpoint> locators)
public void addServers(ConnectionEndpoint... servers)
public void addServers(Iterable<ConnectionEndpoint> servers)
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) throws org.springframework.beans.BeansException
setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
org.springframework.beans.BeansException
protected org.springframework.beans.factory.BeanFactory getBeanFactory()
public void setBeanName(String name)
setBeanName
in interface org.springframework.beans.factory.BeanNameAware
public void setName(String name)
public void setPool(com.gemstone.gemfire.cache.client.Pool pool)
public com.gemstone.gemfire.cache.client.Pool getPool()
public void setFreeConnectionTimeout(int freeConnectionTimeout)
public void setIdleTimeout(long idleTimeout)
public void setKeepAlive(boolean keepAlive)
public void setLoadConditioningInterval(int loadConditioningInterval)
public void setLocators(ConnectionEndpoint[] connectionEndpoints)
public void setLocators(Iterable<ConnectionEndpoint> connectionEndpoints)
public void setMaxConnections(int maxConnections)
public void setMinConnections(int minConnections)
public void setMultiUserAuthentication(boolean multiUserAuthentication)
public void setPingInterval(long pingInterval)
public void setPrSingleHopEnabled(boolean prSingleHopEnabled)
public void setReadTimeout(int readTimeout)
public void setRetryAttempts(int retryAttempts)
public void setServerGroup(String serverGroup)
public void setServers(ConnectionEndpoint[] connectionEndpoints)
public void setServers(Iterable<ConnectionEndpoint> connectionEndpoints)
public void setSocketBufferSize(int socketBufferSize)
public void setStatisticInterval(int statisticInterval)
public void setSubscriptionAckInterval(int subscriptionAckInterval)
public void setSubscriptionEnabled(boolean subscriptionEnabled)
public void setSubscriptionMessageTrackingTimeout(int subscriptionMessageTrackingTimeout)
public void setSubscriptionRedundancy(int subscriptionRedundancy)
public void setThreadLocalConnections(boolean threadLocalConnections)
public final void setLocatorsConfiguration(Object locatorsConfiguration)
public final void setServersConfiguration(Object serversConfiguration)
Copyright © 2011–2017 Pivotal Software, Inc.. All rights reserved.