Package org.springframework.data.gemfire.client

Class ClientRegionFactoryBean<K,V>

java.lang.Object

org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<Region<K,V>>

org.springframework.data.gemfire.ResolvableRegionFactoryBean<K,V>

org.springframework.data.gemfire.ConfigurableRegionFactoryBean<K,V>

org.springframework.data.gemfire.client.ClientRegionFactoryBean<K,V>

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<Region<K,V>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, EvictingRegionFactoryBean, ExpiringRegionFactoryBean<K,V>, SmartLifecycleSupport

public class ClientRegionFactoryBean<K,V>
extends ConfigurableRegionFactoryBean<K,V>
implements SmartLifecycleSupport, EvictingRegionFactoryBean, ExpiringRegionFactoryBean<K,V>, DisposableBean

Spring FactoryBean used to construct, configure and initialize a client Region.

Author:

Costin Leau, David Turanski, John Blum

See Also:

• CacheListener
• CacheLoader
• CacheWriter
• CustomExpiry
• DataPolicy
• EvictionAttributes
• ExpirationAttributes
• GemFireCache
• Region
• RegionAttributes
• ClientCache
• ClientRegionFactory
• ClientRegionShortcut
• Pool
• Compressor
• DisposableBean
• FactoryBean
• ConfigurableRegionFactoryBean
• PoolResolver
• RegionConfigurer
• EvictingRegionFactoryBean
• ExpiringRegionFactoryBean
• SmartLifecycleSupport

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_POOL_NAME
static final String	GEMFIRE_POOL_NAME

Fields inherited from class org.springframework.data.gemfire.ResolvableRegionFactoryBean

CREATING_REGION_LOG_MESSAGE, REGION_FOUND_LOG_MESSAGE, REGION_NOT_FOUND_ERROR_MESSAGE

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

DEFAULT_SINGLETON

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

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.data.gemfire.support.SmartLifecycleSupport

DEFAULT_AUTO_STARTUP, DEFAULT_IS_RUNNING, DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
ClientRegionFactoryBean()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()	Initializes a the instance of ClientRegionFactoryBean.
protected ClientRegionFactory<K,V>	configure(ClientRegionFactory<K,V> clientRegionFactory)	Configures the given ClientRegionFactoryBean from the configuration settings of this ClientRegionFactoryBean and any RegionAttributes.
protected ClientRegionFactory<K,V>	createClientRegionFactory(ClientCache clientCache, ClientRegionShortcut clientRegionShortcut)	Constructs a new instance of ClientRegionFactory using the given ClientCache and ClientRegionShortcut.
protected Region<K,V>	createRegion(GemFireCache gemfireCache, String regionName)	Creates a new Region with the given name.
void	destroy()	Closes and destroys the Region.
protected RegionAttributes<K,V>	getAttributes()	Gets the RegionAttributes used to configure the client Region created by this ClientRegionFactoryBean.
PoolResolver	getDefaultPoolResolver()	Gets a reference to the configured, default PoolResolver used by this client Region to resolve Pool objects if a explicit PoolResolver was not configured.
Optional<String>	getPoolName()	Returns the name of the configured Pool used by this client Region.
PoolResolver	getPoolResolver()	Gets the configured PoolResolver used by this client Region to resolve Pool objects.
Boolean	getStatisticsEnabled()
protected boolean	isNotPersistent()
protected boolean	isPersistent()
boolean	isStatisticsEnabled()
protected ClientRegionFactory<K,V>	postProcess(ClientRegionFactory<K,V> clientRegionFactory)	Post-process the given ClientRegionFactory setup by this ClientRegionFactoryBean.
protected Region<K,V>	postProcess(Region<K,V> region)	Post-process the Region created by this ClientRegionFactoryBean.
protected boolean	resolveStatisticsEnabled()
void	setAttributes(RegionAttributes<K,V> attributes)	Sets the region attributes used for the region used by this factory.
void	setCacheListeners(CacheListener<K,V>[] cacheListeners)	Sets the cache listeners used for the region used by this factory.
void	setCacheLoader(CacheLoader<K,V> cacheLoader)	Sets the CacheLoader used to load data local to the client's Region on cache misses.
void	setCacheWriter(CacheWriter<K,V> cacheWriter)	Sets the CacheWriter used to perform a synchronous write-behind when data is put into the client's Region.
void	setCloningEnabled(Boolean cloningEnabled)
void	setClose(boolean close)	Indicates whether the region referred by this factory bean will be closed on shutdown (default true).
void	setCompressor(Compressor compressor)	Configures the Compressor used to compress the this Region's data.
void	setConcurrencyChecksEnabled(Boolean concurrencyChecksEnabled)
void	setConcurrencyLevel(Integer concurrencyLevel)
void	setCustomEntryIdleTimeout(CustomExpiry<K,V> customEntryIdleTimeout)
void	setCustomEntryTimeToLive(CustomExpiry<K,V> customEntryTimeToLive)
void	setDataPolicy(DataPolicy dataPolicy)	Sets the Data Policy.
void	setDestroy(boolean destroy)	Indicates whether the region referred by this factory bean will be destroyed on shutdown (default false).
void	setDiskStoreName(String diskStoreName)	Sets the name of disk store to use for overflow and persistence
void	setDiskSynchronous(Boolean diskSynchronous)
void	setEntryIdleTimeout(ExpirationAttributes entryIdleTimeout)
void	setEntryTimeToLive(ExpirationAttributes entryTimeToLive)
void	setEvictionAttributes(EvictionAttributes evictionAttributes)
void	setInitialCapacity(Integer initialCapacity)
void	setInterests(Interest<K>[] interests)	Set the interests for this client region.
void	setKeyConstraint(Class<K> keyConstraint)	Sets a type constraint on this client Region's keys.
void	setLoadFactor(Float loadFactor)
void	setPersistent(boolean persistent)	Configures whether this client Region is persistent, i.e. stores data to disk.
void	setPool(Pool pool)	Configures the Pool used by this client Region.
void	setPoolName(String poolName)	Configures the name of the Pool to be used by this client Region.
void	setPoolResolver(PoolResolver poolResolver)	Sets (configures) the PoolResolver used by this client Region to resolve Pool objects.
void	setRegionIdleTimeout(ExpirationAttributes regionIdleTimeout)
void	setRegionTimeToLive(ExpirationAttributes regionTimeToLive)
void	setShortcut(ClientRegionShortcut shortcut)	Initializes the DataPolicy of the client Region using the given ClientRegionShortcut.
void	setStatisticsEnabled(Boolean statisticsEnabled)
void	setValueConstraint(Class<V> valueConstraint)	Sets a type constraint on this client Region's values.
void	start()	Registers interests in the startup lifecycle phase of the Spring container.

Methods inherited from class org.springframework.data.gemfire.ConfigurableRegionFactoryBean

applyRegionConfigurers, applyRegionConfigurers, applyRegionConfigurers, getCompositeRegionConfigurer, setRegionConfigurers, setRegionConfigurers

Methods inherited from class org.springframework.data.gemfire.ResolvableRegionFactoryBean

getCache, getLookupEnabled, getObject, getObjectType, getParent, getRegion, isLookupEnabled, loadSnapshot, resolveRegionName, setCache, setLookupEnabled, setName, setParent, setRegion, setRegionName, setSnapshot

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

Methods inherited from interface org.springframework.data.gemfire.support.SmartLifecycleSupport

getPhase, isAutoStartup, isRunning, stop, stop

Field Details

DEFAULT_POOL_NAME

public static final String DEFAULT_POOL_NAME

See Also:

• Constant Field Values

GEMFIRE_POOL_NAME

public static final String GEMFIRE_POOL_NAME

See Also:

• Constant Field Values

Constructor Details

ClientRegionFactoryBean

public ClientRegionFactoryBean()

Method Details

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Initializes a the instance of ClientRegionFactoryBean.

Specified by:

afterPropertiesSet in interface InitializingBean

Overrides:

afterPropertiesSet in class ConfigurableRegionFactoryBean<K,V>

Throws:

Exception - if initialization fails.

See Also:

• InitializingBean.afterPropertiesSet()
• ResolvableRegionFactoryBean.createRegion(GemFireCache, String)

createRegion

protected Region<K,V> createRegion(GemFireCache gemfireCache,
 String regionName)

Creates a new Region with the given name.

Overrides:

createRegion in class ResolvableRegionFactoryBean<K,V>

Parameters:

gemfireCache - reference to the GemFireCache.

regionName - name of the new Region.

Returns:

a new Region with the given name.

See Also:

• createClientRegionFactory(ClientCache, ClientRegionShortcut)
• newRegion(ClientRegionFactory, Region, String)
• GemFireCache
• Region

createClientRegionFactory

protected ClientRegionFactory<K,V> createClientRegionFactory(ClientCache clientCache,
 ClientRegionShortcut clientRegionShortcut)

Constructs a new instance of ClientRegionFactory using the given ClientCache and ClientRegionShortcut.

Parameters:

clientCache - reference to the ClientCache.

clientRegionShortcut - ClientRegionShortcut used to configure the client Region DataPolicy.

Returns:

a new instance of ClientRegionFactory.

See Also:

• ClientCache.createClientRegionFactory(ClientRegionShortcut)
• ClientRegionShortcut
• ClientRegionFactory

configure

protected ClientRegionFactory<K,V> configure(ClientRegionFactory<K,V> clientRegionFactory)

Configures the given ClientRegionFactoryBean from the configuration settings of this ClientRegionFactoryBean and any RegionAttributes.

Parameters:

clientRegionFactory - ClientRegionFactory to configure.

Returns:

the configured ClientRegionFactory.

See Also:

• ClientRegionFactory

postProcess

protected ClientRegionFactory<K,V> postProcess(ClientRegionFactory<K,V> clientRegionFactory)

Post-process the given ClientRegionFactory setup by this ClientRegionFactoryBean.

Parameters:

clientRegionFactory - ClientRegionFactory to process.

Returns:

the given ClientRegionFactory.

See Also:

• ClientRegionFactory

postProcess

protected Region<K,V> postProcess(Region<K,V> region)

Post-process the Region created by this ClientRegionFactoryBean.

Overrides:

postProcess in class ResolvableRegionFactoryBean<K,V>

Parameters:

region - Region to process.

See Also:

• Region

start

public void start()

Registers interests in the startup lifecycle phase of the Spring container.

Specified by:

start in interface Lifecycle

See Also:

• ResolvableRegionFactoryBean.getRegion()
• registerInterests(Region)

destroy

public void destroy()
             throws Exception

Closes and destroys the Region.

Specified by:

destroy in interface DisposableBean

Throws:

Exception - if destroy fails.

See Also:

• DisposableBean

setAttributes

public void setAttributes(RegionAttributes<K,V> attributes)

Sets the region attributes used for the region used by this factory. Allows maximum control in specifying the region settings. Used only when a new region is created. Note that using this method allows for advanced customization of the region - while it provides a lot of flexibility, note that it's quite easy to create misconfigured regions (especially in a client/server scenario).

Parameters:

attributes - the attributes to set on a newly created region

getAttributes

protected RegionAttributes<K,V> getAttributes()

Gets the RegionAttributes used to configure the client Region created by this ClientRegionFactoryBean.

Returns:

the RegionAttributes used to configure the client Region.

See Also:

• RegionAttributes

setCacheListeners

public void setCacheListeners(CacheListener<K,V>[] cacheListeners)

Sets the cache listeners used for the region used by this factory. Used only when a new region is created.Overrides the settings specified through setAttributes(RegionAttributes).

Parameters:

cacheListeners - the cacheListeners to set on a newly created region

setCacheLoader

public void setCacheLoader(CacheLoader<K,V> cacheLoader)

Sets the CacheLoader used to load data local to the client's Region on cache misses.

Parameters:

cacheLoader - a GemFire CacheLoader used to load data into the client Region.

See Also:

• CacheLoader

setCacheWriter

public void setCacheWriter(CacheWriter<K,V> cacheWriter)

Sets the CacheWriter used to perform a synchronous write-behind when data is put into the client's Region.

Parameters:

cacheWriter - the GemFire CacheWriter used to perform synchronous write-behinds on put ops.

See Also:

• CacheWriter

setCloningEnabled

public void setCloningEnabled(Boolean cloningEnabled)

setClose

public void setClose(boolean close)

Indicates whether the region referred by this factory bean will be closed on shutdown (default true). Note: destroy and close are mutually exclusive. Enabling one will automatically disable the other.

Parameters:

close - whether to close or not the region

See Also:

• setDestroy(boolean)

setCompressor

public void setCompressor(Compressor compressor)

Configures the Compressor used to compress the this Region's data.

Parameters:

compressor - Compressor used to compress the this Region's data.

See Also:

• Compressor

setConcurrencyChecksEnabled

public void setConcurrencyChecksEnabled(Boolean concurrencyChecksEnabled)

setConcurrencyLevel

public void setConcurrencyLevel(Integer concurrencyLevel)

setCustomEntryIdleTimeout

public void setCustomEntryIdleTimeout(CustomExpiry<K,V> customEntryIdleTimeout)

Specified by:

setCustomEntryIdleTimeout in interface ExpiringRegionFactoryBean<K,V>

setCustomEntryTimeToLive

public void setCustomEntryTimeToLive(CustomExpiry<K,V> customEntryTimeToLive)

Specified by:

setCustomEntryTimeToLive in interface ExpiringRegionFactoryBean<K,V>

setDataPolicy

public void setDataPolicy(DataPolicy dataPolicy)

Sets the Data Policy. Used only when a new Region is created.

Parameters:

dataPolicy - the client Region's Data Policy.

See Also:

• DataPolicy

setDestroy

public void setDestroy(boolean destroy)

Indicates whether the region referred by this factory bean will be destroyed on shutdown (default false). Note: destroy and close are mutually exclusive. Enabling one will automatically disable the other.

Parameters:

destroy - whether or not to destroy the region

See Also:

• setClose(boolean)

setDiskStoreName

public void setDiskStoreName(String diskStoreName)

Sets the name of disk store to use for overflow and persistence

Parameters:

diskStoreName - a String specifying the 'name' of the client Region Disk Store.

setDiskSynchronous

public void setDiskSynchronous(Boolean diskSynchronous)

setEntryIdleTimeout

public void setEntryIdleTimeout(ExpirationAttributes entryIdleTimeout)

Specified by:

setEntryIdleTimeout in interface ExpiringRegionFactoryBean<K,V>

setEntryTimeToLive

public void setEntryTimeToLive(ExpirationAttributes entryTimeToLive)

Specified by:

setEntryTimeToLive in interface ExpiringRegionFactoryBean<K,V>

setEvictionAttributes

public void setEvictionAttributes(EvictionAttributes evictionAttributes)

Specified by:

setEvictionAttributes in interface EvictingRegionFactoryBean

setInitialCapacity

public void setInitialCapacity(Integer initialCapacity)

setInterests

public void setInterests(Interest<K>[] interests)

Set the interests for this client region. Both key and regex interest are supported.

Parameters:

interests - the interests to set

setKeyConstraint

public void setKeyConstraint(Class<K> keyConstraint)

Sets a type constraint on this client Region's keys.

Parameters:

keyConstraint - type of this client Region's keys.

See Also:

• Class

setLoadFactor

public void setLoadFactor(Float loadFactor)

isPersistent

protected boolean isPersistent()

isNotPersistent

protected boolean isNotPersistent()

setPersistent

public void setPersistent(boolean persistent)

Configures whether this client Region is persistent, i.e. stores data to disk.

Parameters:

persistent - boolean value used to enable disk persistence.

setPool

public void setPool(Pool pool)

Configures the Pool used by this client Region.

Parameters:

pool - Pool used by this client Region to send/receive data to/from the server.

See Also:

• Pool
• setPoolName(String)

setPoolName

public void setPoolName(String poolName)

Configures the name of the Pool to be used by this client Region.

Parameters:

poolName - String containing the name of the client Pool to be used by this client Region.

See Also:

• getPoolName()
• setPool(Pool)

getPoolName

public Optional<String> getPoolName()

Returns the name of the configured Pool used by this client Region.

Returns:

the Optional name of the configured Pool to be used by this client Region.

See Also:

• setPoolName(String)

setPoolResolver

public void setPoolResolver(@Nullable
 PoolResolver poolResolver)

Sets (configures) the PoolResolver used by this client Region to resolve Pool objects. The Pool objects may be managed or un-managed depending on the PoolResolver implementation.

Parameters:

poolResolver - PoolResolver used to resolve the configured Pool.

See Also:

• PoolResolver

getPoolResolver

@NonNull
public PoolResolver getPoolResolver()

Gets the configured PoolResolver used by this client Region to resolve Pool objects.

Returns:

the configured PoolResolver. If no PoolResolver was configured, then return the default, PoolManagerPoolResolver.

See Also:

• PoolResolver
• getDefaultPoolResolver()

getDefaultPoolResolver

@NonNull
public PoolResolver getDefaultPoolResolver()

Gets a reference to the configured, default PoolResolver used by this client Region to resolve Pool objects if a explicit PoolResolver was not configured. The default PoolResolver uses a composition of the BeanFactoryPoolResolver and PoolManagerPoolResolver to fallback on.

Returns:

the default PoolResolver.

See Also:

• BeanFactoryPoolResolver
• PoolManagerPoolResolver
• PoolResolver

setRegionIdleTimeout

public void setRegionIdleTimeout(ExpirationAttributes regionIdleTimeout)

Specified by:

setRegionIdleTimeout in interface ExpiringRegionFactoryBean<K,V>

setRegionTimeToLive

public void setRegionTimeToLive(ExpirationAttributes regionTimeToLive)

Specified by:

setRegionTimeToLive in interface ExpiringRegionFactoryBean<K,V>

setShortcut

public void setShortcut(ClientRegionShortcut shortcut)

Initializes the DataPolicy of the client Region using the given ClientRegionShortcut.

Parameters:

shortcut - ClientRegionShortcut used to initialize the DataPolicy of this client Region.

See Also:

• ClientRegionShortcut

setStatisticsEnabled

public void setStatisticsEnabled(Boolean statisticsEnabled)

getStatisticsEnabled

public Boolean getStatisticsEnabled()

isStatisticsEnabled

public boolean isStatisticsEnabled()

resolveStatisticsEnabled

protected boolean resolveStatisticsEnabled()

setValueConstraint

public void setValueConstraint(Class<V> valueConstraint)

Sets a type constraint on this client Region's values.

Parameters:

valueConstraint - type of this client Region's values.

See Also:

• Class