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
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:
-
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
ConstructorDescriptionDelegatingPoolAdapter
(Pool delegate) Constructs an instance ofDelegatingPoolAdapter
initialized with the specifiedPool
. -
Method Summary
Modifier and TypeMethodDescriptionvoid
destroy()
void
destroy
(boolean keepAlive) static DelegatingPoolAdapter
protected Pool
int
long
int
int
int
boolean
getName()
int
long
boolean
int
int
int
int
int
int
int
boolean
int
int
int
boolean
boolean
void
-
Constructor Details
-
DelegatingPoolAdapter
Constructs an instance ofDelegatingPoolAdapter
initialized with the specifiedPool
.
-
-
Method Details
-
from
-
getDelegate
-
isDestroyed
public boolean isDestroyed()- Specified by:
isDestroyed
in interfacePool
- Overrides:
isDestroyed
in classPoolAdapter
-
getFreeConnectionTimeout
public int getFreeConnectionTimeout()- Specified by:
getFreeConnectionTimeout
in interfacePool
- Overrides:
getFreeConnectionTimeout
in classFactoryDefaultsPoolAdapter
-
getIdleTimeout
public long getIdleTimeout()- Specified by:
getIdleTimeout
in interfacePool
- Overrides:
getIdleTimeout
in classFactoryDefaultsPoolAdapter
-
getLoadConditioningInterval
public int getLoadConditioningInterval()- Specified by:
getLoadConditioningInterval
in interfacePool
- Overrides:
getLoadConditioningInterval
in classFactoryDefaultsPoolAdapter
-
getLocators
- Specified by:
getLocators
in interfacePool
- Overrides:
getLocators
in classFactoryDefaultsPoolAdapter
-
getMaxConnections
public int getMaxConnections()- Specified by:
getMaxConnections
in interfacePool
- Overrides:
getMaxConnections
in classFactoryDefaultsPoolAdapter
-
getMinConnections
public int getMinConnections()- Specified by:
getMinConnections
in interfacePool
- Overrides:
getMinConnections
in classFactoryDefaultsPoolAdapter
-
getMultiuserAuthentication
public boolean getMultiuserAuthentication()- Specified by:
getMultiuserAuthentication
in interfacePool
- Overrides:
getMultiuserAuthentication
in classFactoryDefaultsPoolAdapter
-
getName
- Specified by:
getName
in interfacePool
- Overrides:
getName
in classFactoryDefaultsPoolAdapter
-
getOnlineLocators
- Specified by:
getOnlineLocators
in interfacePool
- Overrides:
getOnlineLocators
in classFactoryDefaultsPoolAdapter
-
getPendingEventCount
public int getPendingEventCount()- Specified by:
getPendingEventCount
in interfacePool
- Overrides:
getPendingEventCount
in classPoolAdapter
-
getPingInterval
public long getPingInterval()- Specified by:
getPingInterval
in interfacePool
- Overrides:
getPingInterval
in classFactoryDefaultsPoolAdapter
-
getPRSingleHopEnabled
public boolean getPRSingleHopEnabled()- Specified by:
getPRSingleHopEnabled
in interfacePool
- Overrides:
getPRSingleHopEnabled
in classFactoryDefaultsPoolAdapter
-
getQueryService
- Specified by:
getQueryService
in interfacePool
- Overrides:
getQueryService
in classFactoryDefaultsPoolAdapter
-
getReadTimeout
public int getReadTimeout()- Specified by:
getReadTimeout
in interfacePool
- Overrides:
getReadTimeout
in classFactoryDefaultsPoolAdapter
-
getRetryAttempts
public int getRetryAttempts()- Specified by:
getRetryAttempts
in interfacePool
- Overrides:
getRetryAttempts
in classFactoryDefaultsPoolAdapter
-
getServerConnectionTimeout
public int getServerConnectionTimeout()- Specified by:
getServerConnectionTimeout
in interfacePool
- Overrides:
getServerConnectionTimeout
in classFactoryDefaultsPoolAdapter
-
getServerGroup
- Specified by:
getServerGroup
in interfacePool
- Overrides:
getServerGroup
in classFactoryDefaultsPoolAdapter
-
getServers
- Specified by:
getServers
in interfacePool
- Overrides:
getServers
in classFactoryDefaultsPoolAdapter
-
getSocketBufferSize
public int getSocketBufferSize()- Specified by:
getSocketBufferSize
in interfacePool
- Overrides:
getSocketBufferSize
in classFactoryDefaultsPoolAdapter
-
getSocketConnectTimeout
public int getSocketConnectTimeout()- Specified by:
getSocketConnectTimeout
in interfacePool
- Overrides:
getSocketConnectTimeout
in classFactoryDefaultsPoolAdapter
-
getSocketFactory
- Specified by:
getSocketFactory
in interfacePool
- Overrides:
getSocketFactory
in classFactoryDefaultsPoolAdapter
-
getStatisticInterval
public int getStatisticInterval()- Specified by:
getStatisticInterval
in interfacePool
- Overrides:
getStatisticInterval
in classFactoryDefaultsPoolAdapter
-
getSubscriptionAckInterval
public int getSubscriptionAckInterval()- Specified by:
getSubscriptionAckInterval
in interfacePool
- Overrides:
getSubscriptionAckInterval
in classFactoryDefaultsPoolAdapter
-
getSubscriptionEnabled
public boolean getSubscriptionEnabled()- Specified by:
getSubscriptionEnabled
in interfacePool
- Overrides:
getSubscriptionEnabled
in classFactoryDefaultsPoolAdapter
-
getSubscriptionMessageTrackingTimeout
public int getSubscriptionMessageTrackingTimeout()- Specified by:
getSubscriptionMessageTrackingTimeout
in interfacePool
- Overrides:
getSubscriptionMessageTrackingTimeout
in classFactoryDefaultsPoolAdapter
-
getSubscriptionRedundancy
public int getSubscriptionRedundancy()- Specified by:
getSubscriptionRedundancy
in interfacePool
- Overrides:
getSubscriptionRedundancy
in classFactoryDefaultsPoolAdapter
-
getSubscriptionTimeoutMultiplier
public int getSubscriptionTimeoutMultiplier()- Specified by:
getSubscriptionTimeoutMultiplier
in interfacePool
- Overrides:
getSubscriptionTimeoutMultiplier
in classFactoryDefaultsPoolAdapter
-
getThreadLocalConnections
public boolean getThreadLocalConnections()- Specified by:
getThreadLocalConnections
in interfacePool
- Overrides:
getThreadLocalConnections
in classFactoryDefaultsPoolAdapter
-
destroy
public void destroy()- Specified by:
destroy
in interfacePool
- Overrides:
destroy
in classFactoryDefaultsPoolAdapter
-
destroy
public void destroy(boolean keepAlive) - Specified by:
destroy
in interfacePool
- Overrides:
destroy
in classPoolAdapter
-
releaseThreadLocalConnection
public void releaseThreadLocalConnection()- Specified by:
releaseThreadLocalConnection
in interfacePool
- Overrides:
releaseThreadLocalConnection
in classPoolAdapter
-