org.springframework.data.gemfire.util

Class DistributedSystemUtils

java.lang.Object

org.springframework.data.gemfire.util.SpringUtils

org.springframework.data.gemfire.util.DistributedSystemUtils

Direct Known Subclasses:

CacheUtils

public abstract class DistributedSystemUtils
extends SpringUtils

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

Since:

1.7.0

Author:

John Blum

See Also:

GemFireCache, DistributedSystem, DistributionConfig, InternalDistributedSystem, DistributionLocator

Nested Class Summary

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

SpringUtils.OrderedBeanWrapper<T>, SpringUtils.ValueReturningThrowableOperation<T>, SpringUtils.VoidReturningExceptionThrowingOperation, SpringUtils.VoidReturningThrowableOperation

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
DistributedSystemUtils()

Method Summary

Modifier and Type	Method and 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.SpringUtils

addDependsOn, defaultIfEmpty, defaultIfEmpty, defaultIfNull, defaultIfNull, dereferenceBean, equalsIgnoreNull, getBeansOfTypeOrdered, getBeansOfTypeOrdered, getOrder, getOrderedStreamOfBeansByType, getPropertyValue, isMatchingBean, nullOrEquals, nullSafeEquals, nullSafeName, nullSafeSimpleName, nullSafeType, nullSafeType, 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 Detail

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

See Also:

Constant Field Values

DURABLE_CLIENT_TIMEOUT_PROPERTY_NAME

public static final String DURABLE_CLIENT_TIMEOUT_PROPERTY_NAME

See Also:

Constant Field Values

GEMFIRE_PREFIX

public static final String GEMFIRE_PREFIX

See Also:

Constant Field Values

NAME_PROPERTY_NAME

public static final String NAME_PROPERTY_NAME

See Also:

Constant Field Values

Constructor Detail

DistributedSystemUtils

public DistributedSystemUtils()

Method Detail

configureDurableClient

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

isConnected

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

isNotConnected

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

getDistributedSystem

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

getDistributedSystem

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

getLocator

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