Package 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 base class and default, no-op implementation of the Pool interface that conveniently enables implementing classes to extend this adapter and choose which Pool methods/operations are supported by this implementation. 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 no actual connections or operating state information (e.g. pendingEventCount) is needed.
Since:
1.8.0
See Also:

  • Field Details

  • Constructor Details

    • PoolAdapter

      public PoolAdapter()

  • Method Details

    • 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

    • getOnlineLocators

      public List<InetSocketAddress> getOnlineLocators()
      Specified by:
      getOnlineLocators 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

    • getPRSingleHopEnabled

      public boolean getPRSingleHopEnabled()
      Specified by:
      getPRSingleHopEnabled 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

    • getServerConnectionTimeout

      public int getServerConnectionTimeout()
      Specified by:
      getServerConnectionTimeout 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

    • getSocketConnectTimeout

      public int getSocketConnectTimeout()
      Specified by:
      getSocketConnectTimeout in interface org.apache.geode.cache.client.Pool

    • getSocketFactory

      public org.apache.geode.cache.client.SocketFactory getSocketFactory()
      Specified by:
      getSocketFactory 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

    • getSubscriptionTimeoutMultiplier

      public int getSubscriptionTimeoutMultiplier()
      Specified by:
      getSubscriptionTimeoutMultiplier in interface org.apache.geode.cache.client.Pool

    • getThreadLocalConnections

      public boolean getThreadLocalConnections()

    • 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()