DelegatingPoolAdapter (Spring Data for Pivotal GemFire 2.2.13.RELEASE API)

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:

org.apache.geode.cache.client.Pool
```
public abstract class DelegatingPoolAdapter
extends FactoryDefaultsPoolAdapter
```
DelegatingPoolAdapter is an abstract implementation of Pivotal 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:

Pool, 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 and Description
`DelegatingPoolAdapter(org.apache.geode.cache.client.Pool delegate)` Constructs an instance of `DelegatingPoolAdapter` initialized with the specified `Pool`.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and 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()`
`String`	`getServerGroup()`
`List<InetSocketAddress>`	`getServers()`
`int`	`getSocketBufferSize()`
`int`	`getSocketConnectTimeout()`
`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 Detail
  - 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 Detail
  - 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
  - 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
  - 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
  - getThreadLocalConnections
```
public boolean getThreadLocalConnections()
```
    Specified by:
    
    getThreadLocalConnections in interface org.apache.geode.cache.client.Pool
    
    Overrides:
    
    getThreadLocalConnections 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
  - releaseThreadLocalConnection
```
public void releaseThreadLocalConnection()
```
    Specified by:
    
    releaseThreadLocalConnection in interface org.apache.geode.cache.client.Pool
    
    Overrides:
    
    releaseThreadLocalConnection in class PoolAdapter

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 java.lang.Object

Constructor Detail

DelegatingPoolAdapter

Method Detail

from

getDelegate

isDestroyed

getFreeConnectionTimeout

getIdleTimeout

getLoadConditioningInterval

getLocators

getMaxConnections

getMinConnections

getMultiuserAuthentication

getName

getOnlineLocators

getPendingEventCount

getPingInterval

getPRSingleHopEnabled

getQueryService

getReadTimeout

getRetryAttempts

getServerGroup

getServers

getSocketBufferSize

getSocketConnectTimeout

getStatisticInterval

getSubscriptionAckInterval

getSubscriptionEnabled

getSubscriptionMessageTrackingTimeout

getSubscriptionRedundancy

getSubscriptionTimeoutMultiplier

getThreadLocalConnections

destroy

destroy

releaseThreadLocalConnection