org.springframework.data.gemfire.client

Class PoolAdapter

java.lang.Object

org.springframework.data.gemfire.client.PoolAdapter

All Implemented Interfaces:

org.apache.geode.cache.client.Pool

Direct Known Subclasses:

FactoryDefaultsPoolAdapter

public abstract class PoolAdapter
extends Object
implements org.apache.geode.cache.client.Pool

The PoolAdapter class is an abstract, default no-op implementation of the GemFire Pool interface that conveniently enables implementing classes to extend this adapter to adapt their interfaces and serve as a Pool. For instance, one possible implementation is Spring Data GemFire's PoolFactoryBean, which can act as a Pool in a context where only the Pool's "configuration" and meta-data are required, but not actual connections or operating state information (e.g. pendingEventCount).

Since:

1.8.0

Author:

John Blum

See Also:

PoolFactoryBean, Pool

Field Summary

Fields

Modifier and Type	Field and Description
static String	NOT_IMPLEMENTED

Constructor Summary

Constructors

Constructor and Description
PoolAdapter()

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	destroy(boolean keepAlive)
int	getFreeConnectionTimeout()
long	getIdleTimeout()
int	getLoadConditioningInterval()
List<InetSocketAddress>	getLocators()
int	getMaxConnections()
int	getMinConnections()
boolean	getMultiuserAuthentication()
String	getName()
int	getPendingEventCount()
long	getPingInterval()
boolean	getPRSingleHopEnabled()
org.apache.geode.cache.query.QueryService	getQueryService()
int	getReadTimeout()
int	getRetryAttempts()
String	getServerGroup()
List<InetSocketAddress>	getServers()
int	getSocketBufferSize()
int	getStatisticInterval()
int	getSubscriptionAckInterval()
boolean	getSubscriptionEnabled()
int	getSubscriptionMessageTrackingTimeout()
int	getSubscriptionRedundancy()
boolean	getThreadLocalConnections()
boolean	isDestroyed()
void	releaseThreadLocalConnection()

Methods inherited from class java.lang.Object

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

Field Detail

NOT_IMPLEMENTED

public static final String NOT_IMPLEMENTED

See Also:

Constant Field Values

Constructor Detail

PoolAdapter

public PoolAdapter()

Method Detail

isDestroyed

public boolean isDestroyed()

Specified by:

isDestroyed in interface org.apache.geode.cache.client.Pool

getFreeConnectionTimeout

public int getFreeConnectionTimeout()

Specified by:

getFreeConnectionTimeout in interface org.apache.geode.cache.client.Pool

getIdleTimeout

public long getIdleTimeout()

Specified by:

getIdleTimeout in interface org.apache.geode.cache.client.Pool

getLoadConditioningInterval

public int getLoadConditioningInterval()

Specified by:

getLoadConditioningInterval in interface org.apache.geode.cache.client.Pool

getLocators

public List<InetSocketAddress> getLocators()

Specified by:

getLocators in interface org.apache.geode.cache.client.Pool

getMaxConnections

public int getMaxConnections()

Specified by:

getMaxConnections in interface org.apache.geode.cache.client.Pool

getMinConnections

public int getMinConnections()

Specified by:

getMinConnections in interface org.apache.geode.cache.client.Pool

getMultiuserAuthentication

public boolean getMultiuserAuthentication()

Specified by:

getMultiuserAuthentication in interface org.apache.geode.cache.client.Pool

getName

public String getName()

Specified by:

getName in interface org.apache.geode.cache.client.Pool

getPRSingleHopEnabled

public boolean getPRSingleHopEnabled()

Specified by:

getPRSingleHopEnabled in interface org.apache.geode.cache.client.Pool

getPendingEventCount

public int getPendingEventCount()

Specified by:

getPendingEventCount in interface org.apache.geode.cache.client.Pool

getPingInterval

public long getPingInterval()

Specified by:

getPingInterval in interface org.apache.geode.cache.client.Pool

getQueryService

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

Specified by:

getQueryService in interface org.apache.geode.cache.client.Pool

getReadTimeout

public int getReadTimeout()

Specified by:

getReadTimeout in interface org.apache.geode.cache.client.Pool

getRetryAttempts

public int getRetryAttempts()

Specified by:

getRetryAttempts in interface org.apache.geode.cache.client.Pool

getServerGroup

public String getServerGroup()

Specified by:

getServerGroup in interface org.apache.geode.cache.client.Pool

getServers

public List<InetSocketAddress> getServers()

Specified by:

getServers in interface org.apache.geode.cache.client.Pool

getSocketBufferSize

public int getSocketBufferSize()

Specified by:

getSocketBufferSize in interface org.apache.geode.cache.client.Pool

getStatisticInterval

public int getStatisticInterval()

Specified by:

getStatisticInterval in interface org.apache.geode.cache.client.Pool

getSubscriptionAckInterval

public int getSubscriptionAckInterval()

Specified by:

getSubscriptionAckInterval in interface org.apache.geode.cache.client.Pool

getSubscriptionEnabled

public boolean getSubscriptionEnabled()

Specified by:

getSubscriptionEnabled in interface org.apache.geode.cache.client.Pool

getSubscriptionMessageTrackingTimeout

public int getSubscriptionMessageTrackingTimeout()

Specified by:

getSubscriptionMessageTrackingTimeout in interface org.apache.geode.cache.client.Pool

getSubscriptionRedundancy

public int getSubscriptionRedundancy()

Specified by:

getSubscriptionRedundancy in interface org.apache.geode.cache.client.Pool

getThreadLocalConnections

public boolean getThreadLocalConnections()

Specified by:

getThreadLocalConnections in interface org.apache.geode.cache.client.Pool

destroy

public void destroy()

Specified by:

destroy in interface org.apache.geode.cache.client.Pool

destroy

public void destroy(boolean keepAlive)

Specified by:

destroy in interface org.apache.geode.cache.client.Pool

releaseThreadLocalConnection

public void releaseThreadLocalConnection()

Specified by:

releaseThreadLocalConnection in interface org.apache.geode.cache.client.Pool