Spring Data for VMware GemFire

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

All Implemented Interfaces:: org.apache.geode.cache.client.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

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(org.apache.geode.cache.client.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(org.apache.geode.cache.client.Pool delegate)

protected org.apache.geode.cache.client.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()

org.apache.geode.cache.query.QueryService

getQueryService()

int

getReadTimeout()

int

getRetryAttempts()

int

getServerConnectionTimeout()

String

getServerGroup()

List<InetSocketAddress>

getServers()

int

getSocketBufferSize()

int

getSocketConnectTimeout()

org.apache.geode.cache.client.SocketFactory

getSocketFactory()

int

getStatisticInterval()

int

getSubscriptionAckInterval()

boolean

getSubscriptionEnabled()

int

getSubscriptionMessageTrackingTimeout()

int

getSubscriptionRedundancy()

int

getSubscriptionTimeoutMultiplier()

boolean

isDestroyed()

Methods inherited from class org.springframework.data.gemfire.client.PoolAdapter
getThreadLocalConnections, releaseThreadLocalConnection

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- DelegatingPoolAdapter
  
  public DelegatingPoolAdapter(org.apache.geode.cache.client.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(org.apache.geode.cache.client.Pool delegate)
- getDelegate
  
  protected org.apache.geode.cache.client.Pool getDelegate()
- isDestroyed
  
  public boolean isDestroyed()
  
  Specified by:
  
  isDestroyed in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  isDestroyed in class PoolAdapter
- getFreeConnectionTimeout
  
  public int getFreeConnectionTimeout()
  
  Specified by:
  
  getFreeConnectionTimeout in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getFreeConnectionTimeout in class FactoryDefaultsPoolAdapter
- getIdleTimeout
  
  public long getIdleTimeout()
  
  Specified by:
  
  getIdleTimeout in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getIdleTimeout in class FactoryDefaultsPoolAdapter
- getLoadConditioningInterval
  
  public int getLoadConditioningInterval()
  
  Specified by:
  
  getLoadConditioningInterval in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getLoadConditioningInterval in class FactoryDefaultsPoolAdapter
- getLocators
  
  public List<InetSocketAddress> getLocators()
  
  Specified by:
  
  getLocators in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getLocators in class FactoryDefaultsPoolAdapter
- getMaxConnections
  
  public int getMaxConnections()
  
  Specified by:
  
  getMaxConnections in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getMaxConnections in class FactoryDefaultsPoolAdapter
- getMinConnections
  
  public int getMinConnections()
  
  Specified by:
  
  getMinConnections in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getMinConnections in class FactoryDefaultsPoolAdapter
- getMultiuserAuthentication
  
  public boolean getMultiuserAuthentication()
  
  Specified by:
  
  getMultiuserAuthentication in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getMultiuserAuthentication in class FactoryDefaultsPoolAdapter
- getName
  
  public String getName()
  
  Specified by:
  
  getName in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getName in class FactoryDefaultsPoolAdapter
- getOnlineLocators
  
  public List<InetSocketAddress> getOnlineLocators()
  
  Specified by:
  
  getOnlineLocators in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getOnlineLocators in class FactoryDefaultsPoolAdapter
- getPendingEventCount
  
  public int getPendingEventCount()
  
  Specified by:
  
  getPendingEventCount in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getPendingEventCount in class PoolAdapter
- getPingInterval
  
  public long getPingInterval()
  
  Specified by:
  
  getPingInterval in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getPingInterval in class FactoryDefaultsPoolAdapter
- getPRSingleHopEnabled
  
  public boolean getPRSingleHopEnabled()
  
  Specified by:
  
  getPRSingleHopEnabled in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getPRSingleHopEnabled in class FactoryDefaultsPoolAdapter
- getQueryService
  
  public org.apache.geode.cache.query.QueryService getQueryService()
  
  Specified by:
  
  getQueryService in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getQueryService in class FactoryDefaultsPoolAdapter
- getReadTimeout
  
  public int getReadTimeout()
  
  Specified by:
  
  getReadTimeout in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getReadTimeout in class FactoryDefaultsPoolAdapter
- getRetryAttempts
  
  public int getRetryAttempts()
  
  Specified by:
  
  getRetryAttempts in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getRetryAttempts in class FactoryDefaultsPoolAdapter
- getServerConnectionTimeout
  
  public int getServerConnectionTimeout()
  
  Specified by:
  
  getServerConnectionTimeout in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getServerConnectionTimeout in class FactoryDefaultsPoolAdapter
- getServerGroup
  
  public String getServerGroup()
  
  Specified by:
  
  getServerGroup in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getServerGroup in class FactoryDefaultsPoolAdapter
- getServers
  
  public List<InetSocketAddress> getServers()
  
  Specified by:
  
  getServers in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getServers in class FactoryDefaultsPoolAdapter
- getSocketBufferSize
  
  public int getSocketBufferSize()
  
  Specified by:
  
  getSocketBufferSize in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSocketBufferSize in class FactoryDefaultsPoolAdapter
- getSocketConnectTimeout
  
  public int getSocketConnectTimeout()
  
  Specified by:
  
  getSocketConnectTimeout in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSocketConnectTimeout in class FactoryDefaultsPoolAdapter
- getSocketFactory
  
  public org.apache.geode.cache.client.SocketFactory getSocketFactory()
  
  Specified by:
  
  getSocketFactory in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSocketFactory in class FactoryDefaultsPoolAdapter
- getStatisticInterval
  
  public int getStatisticInterval()
  
  Specified by:
  
  getStatisticInterval in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getStatisticInterval in class FactoryDefaultsPoolAdapter
- getSubscriptionAckInterval
  
  public int getSubscriptionAckInterval()
  
  Specified by:
  
  getSubscriptionAckInterval in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSubscriptionAckInterval in class FactoryDefaultsPoolAdapter
- getSubscriptionEnabled
  
  public boolean getSubscriptionEnabled()
  
  Specified by:
  
  getSubscriptionEnabled in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSubscriptionEnabled in class FactoryDefaultsPoolAdapter
- getSubscriptionMessageTrackingTimeout
  
  public int getSubscriptionMessageTrackingTimeout()
  
  Specified by:
  
  getSubscriptionMessageTrackingTimeout in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSubscriptionMessageTrackingTimeout in class FactoryDefaultsPoolAdapter
- getSubscriptionRedundancy
  
  public int getSubscriptionRedundancy()
  
  Specified by:
  
  getSubscriptionRedundancy in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSubscriptionRedundancy in class FactoryDefaultsPoolAdapter
- getSubscriptionTimeoutMultiplier
  
  public int getSubscriptionTimeoutMultiplier()
  
  Specified by:
  
  getSubscriptionTimeoutMultiplier in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  getSubscriptionTimeoutMultiplier in class FactoryDefaultsPoolAdapter
- destroy
  
  public void destroy()
  
  Specified by:
  
  destroy in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  destroy in class FactoryDefaultsPoolAdapter
- destroy
  
  public void destroy(boolean keepAlive)
  
  Specified by:
  
  destroy in interface org.apache.geode.cache.client.Pool
  
  Overrides:
  
  destroy in class PoolAdapter

Spring Data for VMware GemFire

Class DelegatingPoolAdapter

Field Summary

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

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Constructor Details

DelegatingPoolAdapter

Method Details

from

getDelegate

isDestroyed

getFreeConnectionTimeout

getIdleTimeout

getLoadConditioningInterval

getLocators

getMaxConnections

getMinConnections

getMultiuserAuthentication

getName

getOnlineLocators

getPendingEventCount

getPingInterval

getPRSingleHopEnabled

getQueryService

getReadTimeout

getRetryAttempts

getServerConnectionTimeout

getServerGroup

getServers

getSocketBufferSize

getSocketConnectTimeout

getSocketFactory

getStatisticInterval

getSubscriptionAckInterval

getSubscriptionEnabled

getSubscriptionMessageTrackingTimeout

getSubscriptionRedundancy

getSubscriptionTimeoutMultiplier

destroy

destroy