org.springframework.data.gemfire.server

Class CacheServerFactoryBean

java.lang.Object

org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<org.apache.geode.cache.server.CacheServer>

org.springframework.data.gemfire.server.CacheServerFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<org.apache.geode.cache.server.CacheServer>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class CacheServerFactoryBean
extends AbstractFactoryBeanSupport<org.apache.geode.cache.server.CacheServer>
implements DisposableBean, InitializingBean, SmartLifecycle

Spring FactoryBean used to construct, configure and initialize a CacheServer.

Author:

Costin Leau, John Blum

See Also:

Cache, ClientCache, CacheServer, DisposableBean, FactoryBean, InitializingBean, SmartLifecycle, CacheServerConfigurer, AbstractFactoryBeanSupport

Field Summary

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

DEFAULT_SINGLETON

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor and Description
CacheServerFactoryBean()

Method Summary

Modifier and Type	Method and Description
protected org.apache.geode.cache.server.CacheServer	addCacheServer(org.apache.geode.cache.Cache cache) Adds a CacheServer to the given Cache for server cache clients.
void	afterPropertiesSet()
protected void	applyCacheServerConfigurers(CacheServerConfigurer... cacheServerConfigurers) Null-safe operation to apply the given array of CacheServerConfigurers to this CacheServerFactoryBean.
protected void	applyCacheServerConfigurers(Iterable<CacheServerConfigurer> cacheServerConfigurers) Null-safe operation to apply the given Iterable of CacheServerConfigurers to this CacheServerFactoryBean.
protected org.apache.geode.cache.server.CacheServer	configure(org.apache.geode.cache.server.CacheServer cacheServer) Configures the provided CacheServer with any custom, application-specific configuration.
void	destroy()
protected CacheServerConfigurer	getCompositeCacheServerConfigurer() Returns a reference to the Composite CacheServerConfigurer used to apply additional configuration to this CacheServerFactoryBean on Spring container initialization.
org.apache.geode.cache.server.CacheServer	getObject()
Class<?>	getObjectType()
int	getPhase() Start at the latest possible moment.
boolean	isAutoStartup()
boolean	isRunning()
protected org.apache.geode.cache.server.CacheServer	postProcess(org.apache.geode.cache.server.CacheServer cacheServer) Post-process the CacheServer with any necessary follow-up actions.
void	setAutoStartup(boolean autoStartup)
void	setBindAddress(String bindAddress)
void	setCache(org.apache.geode.cache.Cache cache)
void	setCacheServerConfigurers(CacheServerConfigurer... cacheServerConfigurers) Null-safe operation to set an array of CacheServerConfigurers used to apply additional configuration to this CacheServerFactoryBean when using Annotation-based configuration.
void	setCacheServerConfigurers(List<CacheServerConfigurer> cacheServerConfigurers) Null-safe operation to set an Iterable of CacheServerConfigurers used to apply additional configuration to this CacheServerFactoryBean when using Annotation-based configuration.
void	setHostNameForClients(String hostNameForClients)
void	setListeners(Set<org.apache.geode.cache.InterestRegistrationListener> listeners)
void	setLoadPollInterval(long loadPollInterval)
void	setMaxConnections(int maxConnections)
void	setMaxMessageCount(int maxMessageCount)
void	setMaxThreads(int maxThreads)
void	setMaxTimeBetweenPings(int maxTimeBetweenPings)
void	setMessageTimeToLive(int messageTimeToLive)
void	setNotifyBySubscription(boolean notifyBySubscription)
void	setPort(int port)
void	setServerGroups(String[] serverGroups)
void	setServerLoadProbe(org.apache.geode.cache.server.ServerLoadProbe serverLoadProbe)
void	setSocketBufferSize(int socketBufferSize)
void	setSubscriptionCapacity(int subscriptionCapacity)
void	setSubscriptionDiskStore(String diskStoreName)
void	setSubscriptionEvictionPolicy(SubscriptionEvictionPolicy evictionPolicy)
void	setTcpNoDelay(boolean tcpNoDelay)
void	start()
void	stop()
void	stop(Runnable callback)

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

getBeanClassLoader, getBeanFactory, getBeanName, getLog, isSingleton, logDebug, logDebug, logError, logError, logInfo, logInfo, logWarning, logWarning, newLog, setBeanClassLoader, setBeanFactory, setBeanName

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheServerFactoryBean

public CacheServerFactoryBean()

Method Detail

afterPropertiesSet

public void afterPropertiesSet()
                        throws IOException

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

IOException

applyCacheServerConfigurers

protected void applyCacheServerConfigurers(CacheServerConfigurer... cacheServerConfigurers)

Null-safe operation to apply the given array of CacheServerConfigurers to this CacheServerFactoryBean.

Parameters:

cacheServerConfigurers - array of CacheServerConfigurers applied to this CacheServerFactoryBean.

See Also:

CacheServerConfigurer, applyCacheServerConfigurers(Iterable)

applyCacheServerConfigurers

protected void applyCacheServerConfigurers(Iterable<CacheServerConfigurer> cacheServerConfigurers)

Null-safe operation to apply the given Iterable of CacheServerConfigurers to this CacheServerFactoryBean.

Parameters:

cacheServerConfigurers - Iterable of CacheServerConfigurers applied to this CacheServerFactoryBean.

See Also:

CacheServerConfigurer

addCacheServer

protected org.apache.geode.cache.server.CacheServer addCacheServer(org.apache.geode.cache.Cache cache)

Adds a CacheServer to the given Cache for server cache clients.

Parameters:

cache - Cache used to add a CacheServer.

Returns:

the newly added CacheServer.

See Also:

Cache.addCacheServer(), CacheServer

configure

protected org.apache.geode.cache.server.CacheServer configure(org.apache.geode.cache.server.CacheServer cacheServer)

Configures the provided CacheServer with any custom, application-specific configuration.

Parameters:

cacheServer - CacheServer to configure.

Returns:

the given CacheServer.

See Also:

CacheServer

postProcess

protected org.apache.geode.cache.server.CacheServer postProcess(org.apache.geode.cache.server.CacheServer cacheServer)

Post-process the CacheServer with any necessary follow-up actions.

Parameters:

cacheServer - CacheServer to process.

Returns:

the given CacheServer.

See Also:

CacheServer

getCompositeCacheServerConfigurer

protected CacheServerConfigurer getCompositeCacheServerConfigurer()

Returns a reference to the Composite CacheServerConfigurer used to apply additional configuration to this CacheServerFactoryBean on Spring container initialization.

Returns:

the Composite CacheServerConfigurer.

See Also:

CacheServerConfigurer

getObject

public org.apache.geode.cache.server.CacheServer getObject()

Specified by:

getObject in interface FactoryBean<org.apache.geode.cache.server.CacheServer>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<org.apache.geode.cache.server.CacheServer>

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

getPhase

public int getPhase()

Start at the latest possible moment.

Specified by:

getPhase in interface Phased

Specified by:

getPhase in interface SmartLifecycle

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

setAutoStartup

public void setAutoStartup(boolean autoStartup)

setBindAddress

public void setBindAddress(String bindAddress)

setCache

public void setCache(org.apache.geode.cache.Cache cache)

setCacheServerConfigurers

public void setCacheServerConfigurers(CacheServerConfigurer... cacheServerConfigurers)

Null-safe operation to set an array of CacheServerConfigurers used to apply additional configuration to this CacheServerFactoryBean when using Annotation-based configuration.

Parameters:

cacheServerConfigurers - array of CacheServerConfigurers used to apply additional configuration to this CacheServerFactoryBean.

See Also:

PeerCacheConfigurer, setCacheServerConfigurers(List)

setCacheServerConfigurers

public void setCacheServerConfigurers(List<CacheServerConfigurer> cacheServerConfigurers)

Null-safe operation to set an Iterable of CacheServerConfigurers used to apply additional configuration to this CacheServerFactoryBean when using Annotation-based configuration.

Parameters:

cacheServerConfigurers - Iterable of CacheServerConfigurers used to apply additional configuration to this CacheServerFactoryBean.

See Also:

PeerCacheConfigurer

setHostNameForClients

public void setHostNameForClients(String hostNameForClients)

setListeners

public void setListeners(Set<org.apache.geode.cache.InterestRegistrationListener> listeners)

setLoadPollInterval

public void setLoadPollInterval(long loadPollInterval)

setMaxConnections

public void setMaxConnections(int maxConnections)

setMaxMessageCount

public void setMaxMessageCount(int maxMessageCount)

setMaxThreads

public void setMaxThreads(int maxThreads)

setMaxTimeBetweenPings

public void setMaxTimeBetweenPings(int maxTimeBetweenPings)

setMessageTimeToLive

public void setMessageTimeToLive(int messageTimeToLive)

setNotifyBySubscription

public void setNotifyBySubscription(boolean notifyBySubscription)

setPort

public void setPort(int port)

setServerGroups

public void setServerGroups(String[] serverGroups)

setServerLoadProbe

public void setServerLoadProbe(org.apache.geode.cache.server.ServerLoadProbe serverLoadProbe)

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

setSubscriptionCapacity

public void setSubscriptionCapacity(int subscriptionCapacity)

setSubscriptionDiskStore

public void setSubscriptionDiskStore(String diskStoreName)

setSubscriptionEvictionPolicy

public void setSubscriptionEvictionPolicy(SubscriptionEvictionPolicy evictionPolicy)

setTcpNoDelay

public void setTcpNoDelay(boolean tcpNoDelay)