Package org.springframework.data.gemfire.util

Class DistributedSystemUtils

java.lang.Object

org.springframework.data.gemfire.util.SpringExtensions

org.springframework.data.gemfire.util.DistributedSystemUtils

Direct Known Subclasses:

CacheUtils

public abstract class DistributedSystemUtils
extends SpringExtensions

DistributedSystemUtils is an abstract utility class for working with the GemFire DistributedSystem.

Since:

1.7.0

See Also:

• GemFireCache
• DistributedSystem
• InternalDistributedSystem
• DistributionLocator

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.data.gemfire.util.SpringExtensions

SpringExtensions.OrderedBeanWrapper<T>, SpringExtensions.ValueReturningThrowableOperation<T>, SpringExtensions.VoidReturningThrowableOperation

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_CACHE_SERVER_PORT
static final int	DEFAULT_LOCATOR_PORT
static final String	DURABLE_CLIENT_ID_PROPERTY_NAME
static final String	DURABLE_CLIENT_TIMEOUT_PROPERTY_NAME
static final String	GEMFIRE_PREFIX
static final String	NAME_PROPERTY_NAME

Constructor Summary

Constructors

Constructor	Description
DistributedSystemUtils()

Method Summary

Modifier and Type	Method	Description
static Properties	configureDurableClient(Properties gemfireProperties, String durableClientId, Integer durableClientTimeout)
static <T extends org.apache.geode.distributed.DistributedSystem> T	getDistributedSystem()
static <T extends org.apache.geode.distributed.DistributedSystem> T	getDistributedSystem(org.apache.geode.cache.GemFireCache gemfireCache)
static <T extends org.apache.geode.distributed.Locator> T	getLocator()
static boolean	isConnected(org.apache.geode.distributed.DistributedSystem distributedSystem)
static boolean	isNotConnected(org.apache.geode.distributed.DistributedSystem distributedSystem)

Methods inherited from class org.springframework.data.gemfire.util.SpringExtensions

addDependsOn, areNotNull, defaultIfEmpty, defaultIfEmpty, defaultIfNull, defaultIfNull, dereferenceBean, equalsIgnoreNull, getBeansOfTypeOrdered, getBeansOfTypeOrdered, getOrder, getOrderedStreamOfBeansByType, getPropertyValue, isMatchingBean, nullOrEquals, nullSafeEquals, nullSafeName, nullSafeSimpleName, nullSafeType, nullSafeType, requireObject, requireObject, safeDoOperation, safeDoOperation, safeGetValue, safeGetValue, safeGetValue, safeGetValue, safeRunOperation, safeRunOperation, setPropertyReference, setPropertyValue

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT_CACHE_SERVER_PORT

public static final int DEFAULT_CACHE_SERVER_PORT

See Also:

• Constant Field Values

DEFAULT_LOCATOR_PORT

public static final int DEFAULT_LOCATOR_PORT

See Also:

• Constant Field Values

DURABLE_CLIENT_ID_PROPERTY_NAME

public static final String DURABLE_CLIENT_ID_PROPERTY_NAME

DURABLE_CLIENT_TIMEOUT_PROPERTY_NAME

public static final String DURABLE_CLIENT_TIMEOUT_PROPERTY_NAME

GEMFIRE_PREFIX

public static final String GEMFIRE_PREFIX

See Also:

• Constant Field Values

NAME_PROPERTY_NAME

public static final String NAME_PROPERTY_NAME

Constructor Details

DistributedSystemUtils

public DistributedSystemUtils()

Method Details

configureDurableClient

@NonNull
public static Properties configureDurableClient(@NonNull
 Properties gemfireProperties,
 @Nullable
 String durableClientId,
 @Nullable
 Integer durableClientTimeout)

isConnected

public static boolean isConnected(@Nullable
 org.apache.geode.distributed.DistributedSystem distributedSystem)

isNotConnected

public static boolean isNotConnected(@Nullable
 org.apache.geode.distributed.DistributedSystem distributedSystem)

getDistributedSystem

@Nullable
public static <T extends org.apache.geode.distributed.DistributedSystem>
T getDistributedSystem()

getDistributedSystem

@Nullable
public static <T extends org.apache.geode.distributed.DistributedSystem>
T getDistributedSystem(org.apache.geode.cache.GemFireCache gemfireCache)

getLocator

@Nullable
public static <T extends org.apache.geode.distributed.Locator>
T getLocator()