Package org.springframework.data.gemfire.client.support

Class DelegatingPoolAdapter

java.lang.Object

org.springframework.data.gemfire.client.PoolAdapter

org.springframework.data.gemfire.client.support.FactoryDefaultsPoolAdapter

org.springframework.data.gemfire.client.support.DelegatingPoolAdapter

All Implemented Interfaces:

Pool

public abstract class DelegatingPoolAdapter
extends FactoryDefaultsPoolAdapter

DelegatingPoolAdapter is an abstract implementation of GemFire's Pool interface and extension of FactoryDefaultsPoolAdapter that delegates operations to the provided Pool instance. However, this implementation guards against a potentially null Pool reference by returning default factory settings for the Pool's configuration properties along with default behavior for operations when the Pool reference is null.

Since:

1.8.0

Author:

John Blum

See Also:

• InetSocketAddress
• Pool
• SocketFactory
• QueryService
• FactoryDefaultsPoolAdapter

Field Summary

Fields inherited from class org.springframework.data.gemfire.client.support.FactoryDefaultsPoolAdapter

DEFAULT_KEEP_ALIVE, DEFAULT_POOL_NAME, LOCALHOST

Fields inherited from class org.springframework.data.gemfire.client.PoolAdapter

NOT_IMPLEMENTED

Constructor Summary

Constructors

Constructor	Description
DelegatingPoolAdapter(Pool delegate)	Constructs an instance of DelegatingPoolAdapter initialized with the specified Pool.

Method Summary

Modifier and Type	Method	Description
void	destroy()
void	destroy(boolean keepAlive)
static DelegatingPoolAdapter	from(Pool delegate)
protected Pool	getDelegate()
int	getFreeConnectionTimeout()
long	getIdleTimeout()
int	getLoadConditioningInterval()
List<InetSocketAddress>	getLocators()
int	getMaxConnections()
int	getMinConnections()
boolean	getMultiuserAuthentication()
String	getName()
List<InetSocketAddress>	getOnlineLocators()
int	getPendingEventCount()
long	getPingInterval()
boolean	getPRSingleHopEnabled()
QueryService	getQueryService()
int	getReadTimeout()
int	getRetryAttempts()
int	getServerConnectionTimeout()
String	getServerGroup()
List<InetSocketAddress>	getServers()
int	getSocketBufferSize()
int	getSocketConnectTimeout()
SocketFactory	getSocketFactory()
int	getStatisticInterval()
int	getSubscriptionAckInterval()
boolean	getSubscriptionEnabled()
int	getSubscriptionMessageTrackingTimeout()
int	getSubscriptionRedundancy()
int	getSubscriptionTimeoutMultiplier()
boolean	getThreadLocalConnections()
boolean	isDestroyed()
void	releaseThreadLocalConnection()

Methods inherited from class java.lang.Object

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

Constructor Details

DelegatingPoolAdapter

public DelegatingPoolAdapter(Pool delegate)

Constructs an instance of DelegatingPoolAdapter initialized with the specified Pool.

Parameters:

delegate - Pool used as the delegate; can be null.

See Also:

• Pool

Method Details

from

public static DelegatingPoolAdapter from(Pool delegate)

getDelegate

protected Pool getDelegate()

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed in interface Pool

Overrides:

isDestroyed in class PoolAdapter

getFreeConnectionTimeout

public int getFreeConnectionTimeout()

Specified by:

getFreeConnectionTimeout in interface Pool

Overrides:

getFreeConnectionTimeout in class FactoryDefaultsPoolAdapter

getIdleTimeout

public long getIdleTimeout()

Specified by:

getIdleTimeout in interface Pool

Overrides:

getIdleTimeout in class FactoryDefaultsPoolAdapter

getLoadConditioningInterval

public int getLoadConditioningInterval()

Specified by:

getLoadConditioningInterval in interface Pool

Overrides:

getLoadConditioningInterval in class FactoryDefaultsPoolAdapter

getLocators

public List<InetSocketAddress> getLocators()

Specified by:

getLocators in interface Pool

Overrides:

getLocators in class FactoryDefaultsPoolAdapter

getMaxConnections

public int getMaxConnections()

Specified by:

getMaxConnections in interface Pool

Overrides:

getMaxConnections in class FactoryDefaultsPoolAdapter

getMinConnections

public int getMinConnections()

Specified by:

getMinConnections in interface Pool

Overrides:

getMinConnections in class FactoryDefaultsPoolAdapter

getMultiuserAuthentication

public boolean getMultiuserAuthentication()

Specified by:

getMultiuserAuthentication in interface Pool

Overrides:

getMultiuserAuthentication in class FactoryDefaultsPoolAdapter

getName

public String getName()

Specified by:

getName in interface Pool

Overrides:

getName in class FactoryDefaultsPoolAdapter

getOnlineLocators

public List<InetSocketAddress> getOnlineLocators()

Specified by:

getOnlineLocators in interface Pool

Overrides:

getOnlineLocators in class FactoryDefaultsPoolAdapter

getPendingEventCount

public int getPendingEventCount()

Specified by:

getPendingEventCount in interface Pool

Overrides:

getPendingEventCount in class PoolAdapter

getPingInterval

public long getPingInterval()

Specified by:

getPingInterval in interface Pool

Overrides:

getPingInterval in class FactoryDefaultsPoolAdapter

getPRSingleHopEnabled

public boolean getPRSingleHopEnabled()

Specified by:

getPRSingleHopEnabled in interface Pool

Overrides:

getPRSingleHopEnabled in class FactoryDefaultsPoolAdapter

getQueryService

public QueryService getQueryService()

Specified by:

getQueryService in interface Pool

Overrides:

getQueryService in class FactoryDefaultsPoolAdapter

getReadTimeout

public int getReadTimeout()

Specified by:

getReadTimeout in interface Pool

Overrides:

getReadTimeout in class FactoryDefaultsPoolAdapter

getRetryAttempts

public int getRetryAttempts()

Specified by:

getRetryAttempts in interface Pool

Overrides:

getRetryAttempts in class FactoryDefaultsPoolAdapter

getServerConnectionTimeout

public int getServerConnectionTimeout()

Specified by:

getServerConnectionTimeout in interface Pool

Overrides:

getServerConnectionTimeout in class FactoryDefaultsPoolAdapter

getServerGroup

public String getServerGroup()

Specified by:

getServerGroup in interface Pool

Overrides:

getServerGroup in class FactoryDefaultsPoolAdapter

getServers

public List<InetSocketAddress> getServers()

Specified by:

getServers in interface Pool

Overrides:

getServers in class FactoryDefaultsPoolAdapter

getSocketBufferSize

public int getSocketBufferSize()

Specified by:

getSocketBufferSize in interface Pool

Overrides:

getSocketBufferSize in class FactoryDefaultsPoolAdapter

getSocketConnectTimeout

public int getSocketConnectTimeout()

Specified by:

getSocketConnectTimeout in interface Pool

Overrides:

getSocketConnectTimeout in class FactoryDefaultsPoolAdapter

getSocketFactory

public SocketFactory getSocketFactory()

Specified by:

getSocketFactory in interface Pool

Overrides:

getSocketFactory in class FactoryDefaultsPoolAdapter

getStatisticInterval

public int getStatisticInterval()

Specified by:

getStatisticInterval in interface Pool

Overrides:

getStatisticInterval in class FactoryDefaultsPoolAdapter

getSubscriptionAckInterval

public int getSubscriptionAckInterval()

Specified by:

getSubscriptionAckInterval in interface Pool

Overrides:

getSubscriptionAckInterval in class FactoryDefaultsPoolAdapter

getSubscriptionEnabled

public boolean getSubscriptionEnabled()

Specified by:

getSubscriptionEnabled in interface Pool

Overrides:

getSubscriptionEnabled in class FactoryDefaultsPoolAdapter

getSubscriptionMessageTrackingTimeout

public int getSubscriptionMessageTrackingTimeout()

Specified by:

getSubscriptionMessageTrackingTimeout in interface Pool

Overrides:

getSubscriptionMessageTrackingTimeout in class FactoryDefaultsPoolAdapter

getSubscriptionRedundancy

public int getSubscriptionRedundancy()

Specified by:

getSubscriptionRedundancy in interface Pool

Overrides:

getSubscriptionRedundancy in class FactoryDefaultsPoolAdapter

getSubscriptionTimeoutMultiplier

public int getSubscriptionTimeoutMultiplier()

Specified by:

getSubscriptionTimeoutMultiplier in interface Pool

Overrides:

getSubscriptionTimeoutMultiplier in class FactoryDefaultsPoolAdapter

getThreadLocalConnections

public boolean getThreadLocalConnections()

Specified by:

getThreadLocalConnections in interface Pool

Overrides:

getThreadLocalConnections in class FactoryDefaultsPoolAdapter

destroy

public void destroy()

Specified by:

destroy in interface Pool

Overrides:

destroy in class FactoryDefaultsPoolAdapter

destroy

public void destroy(boolean keepAlive)

Specified by:

destroy in interface Pool

Overrides:

destroy in class PoolAdapter

releaseThreadLocalConnection

public void releaseThreadLocalConnection()

Specified by:

releaseThreadLocalConnection in interface Pool

Overrides:

releaseThreadLocalConnection in class PoolAdapter