Class DefaultableDelegatingPoolAdapter

java.lang.Object
org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter

public abstract class DefaultableDelegatingPoolAdapter extends Object
The DefaultableDelegatingPoolAdapter class is a wrapper class around Pool allowing default configuration property values to be provided in the case that the Pool's settings were null.
Since:
1.8.0
See Also:
  • Pool
  • Constructor Details

    • DefaultableDelegatingPoolAdapter

      protected DefaultableDelegatingPoolAdapter(org.apache.geode.cache.client.Pool delegate)
  • Method Details

    • from

      public static DefaultableDelegatingPoolAdapter from(org.apache.geode.cache.client.Pool delegate)
    • getDelegate

      protected org.apache.geode.cache.client.Pool getDelegate()
    • setPreference

      protected DefaultableDelegatingPoolAdapter setPreference(org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference preference)
    • getPreference

      protected org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference getPreference()
    • defaultIfNull

      protected <T> T defaultIfNull(T defaultValue, Supplier<T> valueProvider)
    • defaultIfEmpty

      protected <E, T extends Collection<E>> T defaultIfEmpty(T defaultValue, Supplier<T> valueProvider)
    • preferDefault

      public DefaultableDelegatingPoolAdapter preferDefault()
    • prefersDefault

      protected boolean prefersDefault()
    • preferPool

      public DefaultableDelegatingPoolAdapter preferPool()
    • prefersPool

      protected boolean prefersPool()
    • isDestroyed

      public boolean isDestroyed()
    • getFreeConnectionTimeout

      public int getFreeConnectionTimeout(Integer defaultFreeConnectionTimeout)
    • getIdleTimeout

      public long getIdleTimeout(Long defaultIdleTimeout)
    • getLoadConditioningInterval

      public int getLoadConditioningInterval(Integer defaultLoadConditioningInterval)
    • getLocators

      public List<InetSocketAddress> getLocators(List<InetSocketAddress> defaultLocators)
    • getMaxConnections

      public int getMaxConnections(Integer defaultMaxConnections)
    • getMinConnections

      public int getMinConnections(Integer defaultMinConnections)
    • getMultiuserAuthentication

      public boolean getMultiuserAuthentication(Boolean defaultMultiUserAuthentication)
    • getName

      public String getName()
    • getPendingEventCount

      public int getPendingEventCount()
    • getPingInterval

      public long getPingInterval(Long defaultPingInterval)
    • getPRSingleHopEnabled

      public boolean getPRSingleHopEnabled(Boolean defaultPrSingleHopEnabled)
    • getQueryService

      public org.apache.geode.cache.query.QueryService getQueryService(org.apache.geode.cache.query.QueryService defaultQueryService)
    • getReadTimeout

      public int getReadTimeout(Integer defaultReadTimeout)
    • getRetryAttempts

      public int getRetryAttempts(Integer defaultRetryAttempts)
    • getServerConnectionTimeout

      public int getServerConnectionTimeout(Integer defaultServerConnectionTimeout)
    • getServerGroup

      public String getServerGroup(String defaultServerGroup)
    • getServers

      public List<InetSocketAddress> getServers(List<InetSocketAddress> defaultServers)
    • getSocketBufferSize

      public int getSocketBufferSize(Integer defaultSocketBufferSize)
    • getSocketConnectTimeout

      public int getSocketConnectTimeout(Integer defaultSocketConnectTimeout)
    • getSocketFactory

      public org.apache.geode.cache.client.SocketFactory getSocketFactory(org.apache.geode.cache.client.SocketFactory defaultSocketFactory)
    • getStatisticInterval

      public int getStatisticInterval(Integer defaultStatisticInterval)
    • getSubscriptionAckInterval

      public int getSubscriptionAckInterval(Integer defaultSubscriptionAckInterval)
    • getSubscriptionEnabled

      public boolean getSubscriptionEnabled(Boolean defaultSubscriptionEnabled)
    • getSubscriptionMessageTrackingTimeout

      public int getSubscriptionMessageTrackingTimeout(Integer defaultSubscriptionMessageTrackingTimeout)
    • getSubscriptionRedundancy

      public int getSubscriptionRedundancy(Integer defaultSubscriptionRedundancy)
    • getSubscriptionTimeoutMultiplier

      public int getSubscriptionTimeoutMultiplier(Integer defaultSubscriptionTimeoutMultiplier)
    • destroy

      public void destroy()
    • destroy

      public void destroy(boolean keepAlive)