public abstract class DefaultableDelegatingPoolAdapter extends ObjectSE
DefaultableDelegatingPoolAdapter
クラスは、Pool's
設定が null の場合にデフォルトの構成プロパティ値を提供できるようにする、Pool
のラッパークラスです。Pool
修飾子 | コンストラクターと説明 |
---|---|
protected | DefaultableDelegatingPoolAdapter(org.apache.geode.cache.client.Pool delegate) |
修飾子と型 | メソッドと説明 |
---|---|
protected <E,T extends CollectionSE<E>> | defaultIfEmpty(T defaultValue, SupplierSE<T> valueProvider) |
protected <T> T | defaultIfNull(T defaultValue, SupplierSE<T> valueProvider) |
void | destroy() |
void | destroy(boolean keepAlive) |
static DefaultableDelegatingPoolAdapter | from(org.apache.geode.cache.client.Pool delegate) |
protected org.apache.geode.cache.client.Pool | getDelegate() |
int | getFreeConnectionTimeout(IntegerSE defaultFreeConnectionTimeout) |
long | getIdleTimeout(LongSE defaultIdleTimeout) |
int | getLoadConditioningInterval(IntegerSE defaultLoadConditioningInterval) |
ListSE<InetSocketAddressSE> | getLocators(ListSE<InetSocketAddressSE> defaultLocators) |
int | getMaxConnections(IntegerSE defaultMaxConnections) |
int | getMinConnections(IntegerSE defaultMinConnections) |
boolean | getMultiuserAuthentication(BooleanSE defaultMultiUserAuthentication) |
StringSE | getName() |
int | getPendingEventCount() |
long | getPingInterval(LongSE defaultPingInterval) |
protected org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference | getPreference() |
boolean | getPRSingleHopEnabled(BooleanSE defaultPrSingleHopEnabled) |
org.apache.geode.cache.query.QueryService | getQueryService(org.apache.geode.cache.query.QueryService defaultQueryService) |
int | getReadTimeout(IntegerSE defaultReadTimeout) |
int | getRetryAttempts(IntegerSE defaultRetryAttempts) |
StringSE | getServerGroup(StringSE defaultServerGroup) |
ListSE<InetSocketAddressSE> | getServers(ListSE<InetSocketAddressSE> defaultServers) |
int | getSocketBufferSize(IntegerSE defaultSocketBufferSize) |
int | getSocketConnectTimeout(IntegerSE defaultSocketConnectTimeout) |
int | getStatisticInterval(IntegerSE defaultStatisticInterval) |
int | getSubscriptionAckInterval(IntegerSE defaultSubscriptionAckInterval) |
boolean | getSubscriptionEnabled(BooleanSE defaultSubscriptionEnabled) |
int | getSubscriptionMessageTrackingTimeout(IntegerSE defaultSubscriptionMessageTrackingTimeout) |
int | getSubscriptionRedundancy(IntegerSE defaultSubscriptionRedundancy) |
int | getSubscriptionTimeoutMultiplier(IntegerSE defaultSubscriptionTimeoutMultiplier) |
boolean | getThreadLocalConnections(BooleanSE defaultThreadLocalConnections) |
boolean | isDestroyed() |
DefaultableDelegatingPoolAdapter | preferDefault() |
DefaultableDelegatingPoolAdapter | preferPool() |
protected boolean | prefersDefault() |
protected boolean | prefersPool() |
void | releaseThreadLocalConnection() |
protected DefaultableDelegatingPoolAdapter | setPreference(org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference preference) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected DefaultableDelegatingPoolAdapter(org.apache.geode.cache.client.Pool delegate)
public static DefaultableDelegatingPoolAdapter from(org.apache.geode.cache.client.Pool delegate)
protected org.apache.geode.cache.client.Pool getDelegate()
protected DefaultableDelegatingPoolAdapter setPreference(org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference preference)
protected org.springframework.data.gemfire.client.support.DefaultableDelegatingPoolAdapter.Preference getPreference()
protected <T> T defaultIfNull(T defaultValue, SupplierSE<T> valueProvider)
protected <E,T extends CollectionSE<E>> T defaultIfEmpty(T defaultValue, SupplierSE<T> valueProvider)
public DefaultableDelegatingPoolAdapter preferDefault()
protected boolean prefersDefault()
public DefaultableDelegatingPoolAdapter preferPool()
protected boolean prefersPool()
public boolean isDestroyed()
public int getFreeConnectionTimeout(IntegerSE defaultFreeConnectionTimeout)
public long getIdleTimeout(LongSE defaultIdleTimeout)
public int getLoadConditioningInterval(IntegerSE defaultLoadConditioningInterval)
public ListSE<InetSocketAddressSE> getLocators(ListSE<InetSocketAddressSE> defaultLocators)
public int getMaxConnections(IntegerSE defaultMaxConnections)
public int getMinConnections(IntegerSE defaultMinConnections)
public boolean getMultiuserAuthentication(BooleanSE defaultMultiUserAuthentication)
public StringSE getName()
public int getPendingEventCount()
public long getPingInterval(LongSE defaultPingInterval)
public boolean getPRSingleHopEnabled(BooleanSE defaultPrSingleHopEnabled)
public org.apache.geode.cache.query.QueryService getQueryService(org.apache.geode.cache.query.QueryService defaultQueryService)
public int getReadTimeout(IntegerSE defaultReadTimeout)
public int getRetryAttempts(IntegerSE defaultRetryAttempts)
public ListSE<InetSocketAddressSE> getServers(ListSE<InetSocketAddressSE> defaultServers)
public int getSocketBufferSize(IntegerSE defaultSocketBufferSize)
public int getSocketConnectTimeout(IntegerSE defaultSocketConnectTimeout)
public int getStatisticInterval(IntegerSE defaultStatisticInterval)
public int getSubscriptionAckInterval(IntegerSE defaultSubscriptionAckInterval)
public boolean getSubscriptionEnabled(BooleanSE defaultSubscriptionEnabled)
public int getSubscriptionMessageTrackingTimeout(IntegerSE defaultSubscriptionMessageTrackingTimeout)
public int getSubscriptionRedundancy(IntegerSE defaultSubscriptionRedundancy)
public int getSubscriptionTimeoutMultiplier(IntegerSE defaultSubscriptionTimeoutMultiplier)
public boolean getThreadLocalConnections(BooleanSE defaultThreadLocalConnections)
public void destroy()
public void destroy(boolean keepAlive)
public void releaseThreadLocalConnection()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.