org.springframework.data.gemfire.client.support

Class DefaultableDelegatingPoolAdapter

java.lang.Object

org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter

public abstract class DefaultableDelegatingPoolAdapter
extends Object

The DefaultableDelegatingPoolAdapter class is a wrapper class around Pool allowing default configuration property values to be provided in the case that the Pool's settings were null.

Since:

1.8.0

Author:

John Blum

See Also:

Pool

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultableDelegatingPoolAdapter(org.apache.geode.cache.client.Pool delegate)

Method Summary

Modifier and Type	Method and Description
protected <E,T extends Collection<E>> T	defaultIfEmpty(T defaultValue, Supplier<T> valueProvider)
protected <T> T	defaultIfNull(T defaultValue, Supplier<T> valueProvider)
void	destroy()
void	destroy(boolean keepAlive)
static DefaultableDelegatingPoolAdapter	from(org.apache.geode.cache.client.Pool delegate)
protected org.apache.geode.cache.client.Pool	getDelegate()
int	getFreeConnectionTimeout(Integer defaultFreeConnectionTimeout)
long	getIdleTimeout(Long defaultIdleTimeout)
int	getLoadConditioningInterval(Integer defaultLoadConditioningInterval)
List<InetSocketAddress>	getLocators(List<InetSocketAddress> defaultLocators)
int	getMaxConnections(Integer defaultMaxConnections)
int	getMinConnections(Integer defaultMinConnections)
boolean	getMultiuserAuthentication(Boolean defaultMultiUserAuthentication)
String	getName()
int	getPendingEventCount()
long	getPingInterval(Long defaultPingInterval)
protected org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference	getPreference()
boolean	getPRSingleHopEnabled(Boolean defaultPrSingleHopEnabled)
org.apache.geode.cache.query.QueryService	getQueryService(org.apache.geode.cache.query.QueryService defaultQueryService)
int	getReadTimeout(Integer defaultReadTimeout)
int	getRetryAttempts(Integer defaultRetryAttempts)
String	getServerGroup(String defaultServerGroup)
List<InetSocketAddress>	getServers(List<InetSocketAddress> defaultServers)
int	getSocketBufferSize(Integer defaultSocketBufferSize)
int	getSocketConnectTimeout(Integer defaultSocketConnectTimeout)
int	getStatisticInterval(Integer defaultStatisticInterval)
int	getSubscriptionAckInterval(Integer defaultSubscriptionAckInterval)
boolean	getSubscriptionEnabled(Boolean defaultSubscriptionEnabled)
int	getSubscriptionMessageTrackingTimeout(Integer defaultSubscriptionMessageTrackingTimeout)
int	getSubscriptionRedundancy(Integer defaultSubscriptionRedundancy)
int	getSubscriptionTimeoutMultiplier(Integer defaultSubscriptionTimeoutMultiplier)
boolean	getThreadLocalConnections(Boolean defaultThreadLocalConnections)
boolean	isDestroyed()
DefaultableDelegatingPoolAdapter	preferDefault()
DefaultableDelegatingPoolAdapter	preferPool()
protected boolean	prefersDefault()
protected boolean	prefersPool()
void	releaseThreadLocalConnection()
protected DefaultableDelegatingPoolAdapter	setPreference(org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference preference)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultableDelegatingPoolAdapter

protected DefaultableDelegatingPoolAdapter(org.apache.geode.cache.client.Pool delegate)

Method Detail

from

public static DefaultableDelegatingPoolAdapter from(org.apache.geode.cache.client.Pool delegate)

getDelegate

protected org.apache.geode.cache.client.Pool getDelegate()

setPreference

protected DefaultableDelegatingPoolAdapter setPreference(org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference preference)

getPreference

protected org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference getPreference()

defaultIfNull

protected <T> T defaultIfNull(T defaultValue,
                              Supplier<T> valueProvider)

defaultIfEmpty

protected <E,T extends Collection<E>> T defaultIfEmpty(T defaultValue,
                                                       Supplier<T> valueProvider)

preferDefault

public DefaultableDelegatingPoolAdapter preferDefault()

prefersDefault

protected boolean prefersDefault()

preferPool

public DefaultableDelegatingPoolAdapter preferPool()

prefersPool

protected boolean prefersPool()

isDestroyed

public boolean isDestroyed()

getFreeConnectionTimeout

public int getFreeConnectionTimeout(Integer defaultFreeConnectionTimeout)

getIdleTimeout

public long getIdleTimeout(Long defaultIdleTimeout)

getLoadConditioningInterval

public int getLoadConditioningInterval(Integer defaultLoadConditioningInterval)

getLocators

public List<InetSocketAddress> getLocators(List<InetSocketAddress> defaultLocators)

getMaxConnections

public int getMaxConnections(Integer defaultMaxConnections)

getMinConnections

public int getMinConnections(Integer defaultMinConnections)

getMultiuserAuthentication

public boolean getMultiuserAuthentication(Boolean defaultMultiUserAuthentication)

getName

public String getName()

getPendingEventCount

public int getPendingEventCount()

getPingInterval

public long getPingInterval(Long defaultPingInterval)

getPRSingleHopEnabled

public boolean getPRSingleHopEnabled(Boolean defaultPrSingleHopEnabled)

getQueryService

public org.apache.geode.cache.query.QueryService getQueryService(org.apache.geode.cache.query.QueryService defaultQueryService)

getReadTimeout

public int getReadTimeout(Integer defaultReadTimeout)

getRetryAttempts

public int getRetryAttempts(Integer defaultRetryAttempts)

getServerGroup

public String getServerGroup(String defaultServerGroup)

getServers

public List<InetSocketAddress> getServers(List<InetSocketAddress> defaultServers)

getSocketBufferSize

public int getSocketBufferSize(Integer defaultSocketBufferSize)

getSocketConnectTimeout

public int getSocketConnectTimeout(Integer defaultSocketConnectTimeout)

getStatisticInterval

public int getStatisticInterval(Integer defaultStatisticInterval)

getSubscriptionAckInterval

public int getSubscriptionAckInterval(Integer defaultSubscriptionAckInterval)

getSubscriptionEnabled

public boolean getSubscriptionEnabled(Boolean defaultSubscriptionEnabled)

getSubscriptionMessageTrackingTimeout

public int getSubscriptionMessageTrackingTimeout(Integer defaultSubscriptionMessageTrackingTimeout)

getSubscriptionRedundancy

public int getSubscriptionRedundancy(Integer defaultSubscriptionRedundancy)

getSubscriptionTimeoutMultiplier

public int getSubscriptionTimeoutMultiplier(Integer defaultSubscriptionTimeoutMultiplier)

getThreadLocalConnections

public boolean getThreadLocalConnections(Boolean defaultThreadLocalConnections)

destroy

public void destroy()

destroy

public void destroy(boolean keepAlive)

releaseThreadLocalConnection

public void releaseThreadLocalConnection()