org.springframework.data.gemfire.config.annotation

Class AddPoolConfiguration

java.lang.Object

org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

org.springframework.data.gemfire.config.annotation.AddPoolConfiguration

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, ImportBeanDefinitionRegistrar, EnvironmentAware

Direct Known Subclasses:

AddPoolsConfiguration

public class AddPoolConfiguration
extends AbstractAnnotationConfigSupport
implements ImportBeanDefinitionRegistrar

The AddPoolConfiguration class is a Spring ImportBeanDefinitionRegistrar that registers a PoolFactoryBean definition for the Pool configuration meta-data defined in EnablePool annotations.

Since:

1.9.0

Author:

John Blum

See Also:

Pool, BeanFactory, BeanDefinitionBuilder, BeanDefinitionRegistry, ImportBeanDefinitionRegistrar, AnnotationMetadata, PoolFactoryBean, AddPoolsConfiguration, PoolConfigurer, EnablePools, EnablePool, AbstractAnnotationConfigSupport

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

AbstractAnnotationConfigSupport.TypeResolver<T>

Field Summary

Fields inherited from class org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

CURRENT_THREAD_CONTEXT_CLASS_LOADER, INFRASTRUCTURE_ROLES, ORG_SPRINGFRAMEWORK_DATA_GEMFIRE_PACKAGE, ORG_SPRINGFRAMEWORK_PACKAGE, SPRING_DATA_GEMFIRE_PROPERTY_PREFIX

Constructor Summary

Constructors

Constructor and Description
AddPoolConfiguration()

Method Summary

Modifier and Type	Method and Description
protected BeanDefinitionBuilder	configurePoolConnections(String poolName, AnnotationAttributes enablePoolAttributes, BeanDefinitionBuilder poolFactoryBean) Uses the list of GemFire Locator and Server connection endpoint definitions and meta-data to configure the GemFire client Pool used to communicate with the servers in the GemFire cluster.
protected BeanDefinitionBuilder	configurePoolLocators(String poolName, AnnotationAttributes enablePoolAttributes, BeanDefinitionBuilder poolFactoryBean)
protected BeanDefinitionBuilder	configurePoolServers(String poolName, AnnotationAttributes enablePoolAttributes, BeanDefinitionBuilder poolFactoryBean)
protected String	getAndValidatePoolName(Map<String,Object> enablePoolAttributes)
protected Class<? extends Annotation>	getAnnotationType() Returns the cache application Annotation type pertaining to this configuration.
protected ConnectionEndpoint	newConnectionEndpoint(String host, Integer port)
protected ConnectionEndpointList	parseConnectionEndpoints(AnnotationAttributes enablePoolAttributes, String arrayAttributeName, String stringAttributeName, int defaultPort)
void	registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry)
protected void	registerPoolFactoryBeanDefinition(AnnotationAttributes enablePoolAttributes, BeanDefinitionRegistry registry) Registers a PoolFactoryBean definition in the Spring application context configured with the EnablePool annotation meta-data.

Methods inherited from class org.springframework.data.gemfire.config.annotation.support.AbstractAnnotationConfigSupport

arrayOfPropertyNamesFor, arrayOfPropertyNamesFor, asArrayProperty, cacheClientProperty, cacheCompressionProperty, cacheOffHeapProperty, cachePeerProperty, cacheProperty, cacheServerProperty, clusterProperty, diskStoreProperty, entitiesProperty, gatewayReceiverProperty, gatewaySenderProperty, getAnnotationAttributes, getAnnotationAttributes, getAnnotationAttributes, getAnnotationTypeName, getAnnotationTypeSimpleName, getBeanClassLoader, getBeanFactory, getEnvironment, getEvaluationContext, getLogger, hasValue, hasValue, hasValue, httpServiceProperty, isAnnotationPresent, isAnnotationPresent, isNotInfrastructureBean, isNotInfrastructureBean, isNotInfrastructureClass, isNotInfrastructureRole, isUserLevelMethod, locatorProperty, logDebug, logDebug, logError, logError, loggingProperty, logInfo, logInfo, logWarning, logWarning, managementProperty, managerProperty, memcachedServiceProperty, namedCacheServerProperty, namedDiskStoreProperty, namedGatewaySenderProperty, namedPoolProperty, newEvaluationContext, newLogger, pdxProperty, poolProperty, propertyName, redisServiceProperty, register, register, requireProperty, resolveAnnotation, resolveBeanClass, resolveBeanClass, resolveBeanClass, resolveBeanClassLoader, resolveBeanClassLoader, resolveBeanClassLoader, resolveBeanClassName, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, resolveProperty, safeResolveType, securityProperty, serviceProperty, setBeanClassLoader, setBeanFactory, setEnvironment, sslProperty, statsProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.annotation.ImportBeanDefinitionRegistrar

registerBeanDefinitions

Constructor Detail

AddPoolConfiguration

public AddPoolConfiguration()

Method Detail

getAnnotationType

protected Class<? extends Annotation> getAnnotationType()

Description copied from class: AbstractAnnotationConfigSupport

Returns the cache application Annotation type pertaining to this configuration.

Specified by:

getAnnotationType in class AbstractAnnotationConfigSupport

Returns:

the cache application Annotation type used by this application.

registerBeanDefinitions

public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata,
                                    BeanDefinitionRegistry registry)

Specified by:

registerBeanDefinitions in interface ImportBeanDefinitionRegistrar

registerPoolFactoryBeanDefinition

protected void registerPoolFactoryBeanDefinition(AnnotationAttributes enablePoolAttributes,
                                                 BeanDefinitionRegistry registry)

Registers a PoolFactoryBean definition in the Spring application context configured with the EnablePool annotation meta-data.

Parameters:

enablePoolAttributes - EnablePool annotation attributes.

registry - Spring BeanDefinitionRegistry used to register the PoolFactoryBean definition.

See Also:

BeanDefinitionRegistry, PoolFactoryBean, EnablePool, Map

getAndValidatePoolName

protected String getAndValidatePoolName(Map<String,Object> enablePoolAttributes)

configurePoolConnections

protected BeanDefinitionBuilder configurePoolConnections(String poolName,
                                                         AnnotationAttributes enablePoolAttributes,
                                                         BeanDefinitionBuilder poolFactoryBean)

Uses the list of GemFire Locator and Server connection endpoint definitions and meta-data to configure the GemFire client Pool used to communicate with the servers in the GemFire cluster.

Parameters:

enablePoolAttributes - EnablePool annotation containing Pool Locator/Server connection endpoint meta-data.

See Also:

ClientCacheApplication, Map

configurePoolLocators

protected BeanDefinitionBuilder configurePoolLocators(String poolName,
                                                      AnnotationAttributes enablePoolAttributes,
                                                      BeanDefinitionBuilder poolFactoryBean)

configurePoolServers

protected BeanDefinitionBuilder configurePoolServers(String poolName,
                                                     AnnotationAttributes enablePoolAttributes,
                                                     BeanDefinitionBuilder poolFactoryBean)

parseConnectionEndpoints

protected ConnectionEndpointList parseConnectionEndpoints(AnnotationAttributes enablePoolAttributes,
                                                          String arrayAttributeName,
                                                          String stringAttributeName,
                                                          int defaultPort)

newConnectionEndpoint

protected ConnectionEndpoint newConnectionEndpoint(String host,
                                                   Integer port)