Package org.springframework.data.gemfire.client.support

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)

    • getThreadLocalConnections

      public boolean getThreadLocalConnections(Boolean defaultThreadLocalConnections)

    • destroy

      public void destroy()

    • destroy

      public void destroy(boolean keepAlive)

    • releaseThreadLocalConnection

      public void releaseThreadLocalConnection()