public class PoolFactoryBean extends Object implements FactoryBean<com.gemstone.gemfire.cache.client.Pool>, InitializingBean, DisposableBean, BeanNameAware, BeanFactoryAware
InetSocketAddress,
BeanFactory,
BeanFactoryAware,
BeanNameAware,
DisposableBean,
FactoryBean,
InitializingBean,
ConnectionEndpoint,
ConnectionEndpointList,
Pool,
PoolFactory,
PoolManager,
DistributedSystem| 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 |
afterPropertiesSet() |
protected com.gemstone.gemfire.cache.client.PoolFactory |
createPoolFactory() |
void |
destroy() |
com.gemstone.gemfire.cache.client.Pool |
getObject() |
Class<?> |
getObjectType() |
boolean |
isSingleton() |
protected void |
resolveDistributedSystem()
Attempts to find an existing, running GemFire
DistributedSystem or proceeds to create
a new DistributedSystem if one does not exist. |
protected Properties |
resolveGemfireProperties()
Attempts to resolve existing GemFire System properties from the
ClientCacheFactoryBean
if set by the user. |
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 |
setLocatorEndpointList(ConnectionEndpointList endpointList) |
void |
setLocatorEndpoints(Iterable<ConnectionEndpoint> endpoints) |
void |
setLocators(Iterable<InetSocketAddress> locators)
Deprecated.
|
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 |
setServerEndpointList(ConnectionEndpointList endpointList) |
void |
setServerEndpoints(Iterable<ConnectionEndpoint> endpoints) |
void |
setServerGroup(String serverGroup) |
void |
setServers(Collection<InetSocketAddress> servers)
Deprecated.
|
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 com.gemstone.gemfire.cache.client.Pool getObject()
throws Exception
getObject in interface FactoryBean<com.gemstone.gemfire.cache.client.Pool>Exceptionpublic Class<?> getObjectType()
getObjectType in interface FactoryBean<com.gemstone.gemfire.cache.client.Pool>public boolean isSingleton()
isSingleton in interface FactoryBean<com.gemstone.gemfire.cache.client.Pool>public void afterPropertiesSet()
throws Exception
afterPropertiesSet in interface InitializingBeanExceptionprotected com.gemstone.gemfire.cache.client.PoolFactory createPoolFactory()
protected void resolveDistributedSystem()
DistributedSystem or proceeds to create
a new DistributedSystem if one does not exist.protected Properties resolveGemfireProperties()
ClientCacheFactoryBean
if set by the user.Properties object containing GemFire System properties
or null if no properties were configured.ClientCacheFactoryBean.resolveProperties(),
Propertiespublic void destroy()
throws Exception
destroy in interface DisposableBeanExceptionpublic void setBeanFactory(BeanFactory beanFactory)
setBeanFactory in interface BeanFactoryAwarepublic void setBeanName(String name)
setBeanName in interface BeanNameAwarepublic void setName(String name)
public void setPool(com.gemstone.gemfire.cache.client.Pool pool)
public void setFreeConnectionTimeout(int freeConnectionTimeout)
public void setIdleTimeout(long idleTimeout)
public void setKeepAlive(boolean keepAlive)
@Deprecated public void setLocators(Iterable<InetSocketAddress> locators)
public void setLocatorEndpoints(Iterable<ConnectionEndpoint> endpoints)
public void setLocatorEndpointList(ConnectionEndpointList endpointList)
public void setLoadConditioningInterval(int loadConditioningInterval)
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)
@Deprecated public void setServers(Collection<InetSocketAddress> servers)
public void setServerEndpoints(Iterable<ConnectionEndpoint> endpoints)
public void setServerEndpointList(ConnectionEndpointList endpointList)
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)