SGF-732 - Change branding from Spring Data GemFire to Spring Data for Pivotal GemFire.

Change branding from 'Gemfire' or 'GemFire' to 'Pivotal GemFire'.
This commit is contained in:
John Blum
2018-05-07 23:04:18 -07:00
parent 593b6ad0a0
commit 5babdfd3fb
342 changed files with 1855 additions and 1856 deletions

View File

@@ -907,7 +907,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
}
/**
* Sets an instance of the DynamicRegionSupport to support Dynamic Regions in this GemFire Cache.
* Sets an instance of the DynamicRegionSupport to support Dynamic Regions in this Pivotal GemFire Cache.
*
* @param dynamicRegionSupport the DynamicRegionSupport class to setup Dynamic Regions in this Cache.
*/
@@ -923,10 +923,10 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
}
/**
* Controls whether auto-reconnect functionality introduced in GemFire 8 is enabled or not.
* Controls whether auto-reconnect functionality introduced in Pivotal GemFire 8 is enabled or not.
*
* @param enableAutoReconnect a boolean value to enable/disable auto-reconnect functionality.
* @since GemFire 8.0
* @since Pivotal GemFire 8.0
*/
public void setEnableAutoReconnect(Boolean enableAutoReconnect) {
this.enableAutoReconnect = enableAutoReconnect;
@@ -975,7 +975,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
}
/**
* Requires GemFire 7.0 or higher
* Requires Pivotal GemFire 7.0 or higher
* @param gatewayConflictResolver defined as Object in the signature for backward
* compatibility with Gemfire 6 compatibility. This must be an instance of
* {@link org.apache.geode.cache.util.GatewayConflictResolver}
@@ -1075,7 +1075,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
/**
* Controls whether pdx ignores fields that were unread during
* deserialization. Applicable on GemFire 6.6 or higher.
* deserialization. Applicable on Pivotal GemFire 6.6 or higher.
*
* @param pdxIgnoreUnreadFields the pdxIgnoreUnreadFields to set
*/
@@ -1091,7 +1091,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
}
/**
* Controls whether type metadata for PDX objects is persisted to disk. Applicable on GemFire 6.6 or higher.
* Controls whether type metadata for PDX objects is persisted to disk. Applicable on Pivotal GemFire 6.6 or higher.
*
* @param pdxPersistent a boolean value indicating that PDX type meta-data should be persisted to disk.
*/
@@ -1107,7 +1107,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
}
/**
* Sets the object preference to PdxInstance. Applicable on GemFire 6.6 or higher.
* Sets the object preference to PdxInstance. Applicable on Pivotal GemFire 6.6 or higher.
*
* @param pdxReadSerialized a boolean value indicating the PDX instance should be returned from Region.get(key)
* when available.
@@ -1126,7 +1126,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
/**
* Sets the {@link PdxSerializable} for this cache. Applicable on GemFire
* 6.6 or higher. The argument is of type object for compatibility with
* GemFire 6.5.
* Pivotal GemFire 6.5.
*
* @param serializer pdx serializer configured for this cache.
*/
@@ -1186,7 +1186,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
* Sets the list of TransactionListeners used to configure the Cache to receive transaction events after
* the transaction is processed (committed, rolled back).
*
* @param transactionListeners the list of GemFire TransactionListeners listening for transaction events.
* @param transactionListeners the list of Pivotal GemFire TransactionListeners listening for transaction events.
* @see org.apache.geode.cache.TransactionListener
*/
public void setTransactionListeners(List<TransactionListener> transactionListeners) {
@@ -1204,7 +1204,7 @@ public class CacheFactoryBean extends AbstractFactoryBeanSupport<GemFireCache>
* Sets the TransactionWriter used to configure the Cache for handling transaction events, such as to veto
* the transaction or update an external DB before the commit.
*
* @param transactionWriter the GemFire TransactionWriter callback receiving transaction events.
* @param transactionWriter the Pivotal GemFire TransactionWriter callback receiving transaction events.
* @see org.apache.geode.cache.TransactionWriter
*/
public void setTransactionWriter(TransactionWriter transactionWriter) {

View File

@@ -20,7 +20,7 @@ import org.apache.geode.cache.DataPolicy;
import org.springframework.core.convert.converter.Converter;
/**
* The DataPolicyConverter class converts String values into GemFire DataPolicy enumerated values.
* The DataPolicyConverter class converts String values into Pivotal GemFire DataPolicy enumerated values.
*
* @author David Turanski
* @author John Blum

View File

@@ -43,11 +43,11 @@ public class GemfireAccessor implements InitializingBean {
private Region region;
/**
* Returns the template GemFire Cache Region.
* Returns the template Pivotal GemFire Cache Region.
*
* @param <K> the Region key class type.
* @param <V> the Region value class type.
* @return the GemFire Cache Region.
* @return the Pivotal GemFire Cache Region.
* @see org.apache.geode.cache.Region
*/
@SuppressWarnings("unchecked")
@@ -56,9 +56,9 @@ public class GemfireAccessor implements InitializingBean {
}
/**
* Sets the template GemFire Cache Region.
* Sets the template Pivotal GemFire Cache Region.
*
* @param region the GemFire Cache Region used by this template.
* @param region the Pivotal GemFire Cache Region used by this template.
* @see org.apache.geode.cache.Region
*/
public void setRegion(Region<?, ?> region) {
@@ -92,9 +92,9 @@ public class GemfireAccessor implements InitializingBean {
}
/**
* Converts the given GemFire exception to an appropriate exception from the
* Converts the given Pivotal GemFire exception to an appropriate exception from the
* <code>org.springframework.dao</code> hierarchy. Note that this particular implementation
* is called only for GemFire querying exception that do <b>NOT</b> extend from GemFire exception.
* is called only for Pivotal GemFire querying exception that do <b>NOT</b> extend from Pivotal GemFire exception.
* May be overridden in subclasses.
*
* @param ex GemFireException that occurred

View File

@@ -76,7 +76,7 @@ import org.springframework.dao.TypeMismatchDataAccessException;
import org.springframework.util.ClassUtils;
/**
* Helper class featuring methods for GemFire Cache or Region handling.
* Helper class featuring methods for Pivotal GemFire Cache or Region handling.
*
* @author Costin Leau
*/
@@ -297,7 +297,7 @@ public abstract class GemfireCacheUtils {
/**
* Converts the given (unchecked) Gemfire exception to an appropriate one from the
* <code>org.springframework.dao</code> hierarchy. This method exists to handle backwards compatibility
* for exceptions that had their parents changed in GemFire 6.5.
* for exceptions that had their parents changed in Pivotal GemFire 6.5.
*
* @param ex Gemfire unchecked exception
* @return new the corresponding DataAccessException instance
@@ -309,7 +309,7 @@ public abstract class GemfireCacheUtils {
/**
* Converts the given (unchecked) Gemfire exception to an appropriate one from the
* <code>org.springframework.dao</code> hierarchy. This method exists to handle backwards compatibility
* for exceptions that had their parents changed in GemFire 6.5.
* for exceptions that had their parents changed in Pivotal GemFire 6.5.
*
* @param ex Gemfire unchecked exception
* @return new the corresponding DataAccessException instance
@@ -319,7 +319,7 @@ public abstract class GemfireCacheUtils {
}
/**
* Package protected method for detecting CqInvalidException which has been removed in GemFire 6.5 GA.
* Package protected method for detecting CqInvalidException which has been removed in Pivotal GemFire 6.5 GA.
*/
static boolean isCqInvalidException(RuntimeException ex) {
return (CQ_EXCEPTION_CLASS != null && CQ_EXCEPTION_CLASS.isAssignableFrom(ex.getClass()));

View File

@@ -21,7 +21,7 @@ import org.apache.geode.GemFireException;
import org.apache.geode.cache.Region;
/**
* Callback interface for GemFire code. To be used with {@link GemfireTemplate}'s execution methods, often as anonymous
* Callback interface for Pivotal GemFire code. To be used with {@link GemfireTemplate}'s execution methods, often as anonymous
* classes within a method implementation. A typical implementation will call Region.get/put/query to perform some
* operations on stored objects.
*
@@ -41,7 +41,7 @@ public interface GemfireCallback<T> {
* A thrown custom RuntimeException is treated as an application exception: it gets propagated to
* the caller of the template.
*
* @param region the GemFire Cache Region upon which the operation of this callback will be performed.
* @param region the Pivotal GemFire Cache Region upon which the operation of this callback will be performed.
* @return a result object, or <tt>null</tt> if no result.
* @throws GemFireCheckedException for checked Exceptions occurring in GemFire.
* @throws GemFireException for runtime Exceptions occurring in GemFire.

View File

@@ -55,7 +55,7 @@ public interface GemfireOperations {
<K, V> boolean replace(K key, V oldValue, V newValue);
/**
* Executes a GemFire query with the given (optional) parameters and returns the result. Note this method expects the query to return multiple results; for queries that return only one
* Executes a Pivotal GemFire query with the given (optional) parameters and returns the result. Note this method expects the query to return multiple results; for queries that return only one
* element use {@link #findUnique(String, Object...)}.
*
* As oppose, to the {@link #query(String)} method, this method allows for more generic queries (against multiple regions even) to be executed.
@@ -75,7 +75,7 @@ public interface GemfireOperations {
<E> SelectResults<E> find(String query, Object... params) throws InvalidDataAccessApiUsageException;
/**
* Executes a GemFire query with the given (optional) parameters and returns the result. Note this method expects the query to return a single result; for queries that return multiple
* Executes a Pivotal GemFire query with the given (optional) parameters and returns the result. Note this method expects the query to return a single result; for queries that return multiple
* elements use {@link #find(String, Object...)}.
*
* As oppose, to the {@link #query(String)} method, this method allows for more generic queries (against multiple regions even) to be executed.
@@ -113,7 +113,7 @@ public interface GemfireOperations {
* @param <T> type parameter specifying the returned result type.
* @param action callback object that specifies the Gemfire action to execute.
* @return a result object returned by the action, or <code>null</code>.
* @throws org.springframework.dao.DataAccessException in case of GemFire errors.
* @throws org.springframework.dao.DataAccessException in case of Pivotal GemFire errors.
*/
<T> T execute(GemfireCallback<T> action) throws DataAccessException;
@@ -122,9 +122,9 @@ public interface GemfireOperations {
*
* @param <T> type parameter specifying the returned result type.
* @param action callback object that specifies the Gemfire action to execute.
* @param exposeNativeRegion whether to expose the native GemFire region to callback code.
* @param exposeNativeRegion whether to expose the native Pivotal GemFire region to callback code.
* @return a result object returned by the action, or <code>null</code>.
* @throws org.springframework.dao.DataAccessException in case of GemFire errors.
* @throws org.springframework.dao.DataAccessException in case of Pivotal GemFire errors.
*/
<T> T execute(GemfireCallback<T> action, boolean exposeNativeRegion) throws DataAccessException;

View File

@@ -21,7 +21,7 @@ import org.apache.geode.GemFireException;
import org.springframework.dao.UncategorizedDataAccessException;
/**
* GemFire-specific subclass of UncategorizedDataAccessException, for GemFire system errors that do not match any concrete <code>org.springframework.dao</code> exceptions.
* GemFire-specific subclass of UncategorizedDataAccessException, for Pivotal GemFire system errors that do not match any concrete <code>org.springframework.dao</code> exceptions.
*
* @author Costin Leau
*/

View File

@@ -42,14 +42,14 @@ import org.springframework.util.ClassUtils;
import org.springframework.util.StringUtils;
/**
* Helper class that simplifies GemFire data access code and converts {@link GemFireCheckedException} and
* Helper class that simplifies Pivotal GemFire data access code and converts {@link GemFireCheckedException} and
* {@link GemFireException} into Spring {@link DataAccessException}, following the <tt>org.springframework.dao</tt>
* exception hierarchy.
*
* The central method is <tt>execute</tt>, supporting GemFire access code implementing the GemfireCallback interface.
* The central method is <tt>execute</tt>, supporting Pivotal GemFire access code implementing the GemfireCallback interface.
* It provides dedicated handling such that neither the GemfireCallback implementation nor the calling code needs to
* explicitly care about handling {@link Region} life-cycle exceptions.
* Typically used to implement data access or business logic services that use GemFire within their implementation but
* Typically used to implement data access or business logic services that use Pivotal GemFire within their implementation but
* are GemFire-agnostic in their interface. The latter or code calling the latter only have to deal with business
* objects, query objects, and <tt>org.springframework.dao</tt> exceptions.
*
@@ -89,7 +89,7 @@ public class GemfireTemplate extends GemfireAccessor implements GemfireOperation
* <p>As there is often a need to cast to a interface, the exposed proxy implements all interfaces
* implemented by the original {@link Region}. If this is not sufficient, turn this flag to "true".
*
* @param exposeNativeRegion a boolean value to indicate whether the native GemFire Cache Region should be exposed
* @param exposeNativeRegion a boolean value to indicate whether the native Pivotal GemFire Cache Region should be exposed
* to the GemfireCallback.
* @see org.springframework.data.gemfire.GemfireCallback
*/
@@ -98,9 +98,9 @@ public class GemfireTemplate extends GemfireAccessor implements GemfireOperation
}
/**
* Returns whether to expose the native GemFire Cache Region or a Region proxy to the GemfireCallback code.
* Returns whether to expose the native Pivotal GemFire Cache Region or a Region proxy to the GemfireCallback code.
*
* @return a boolean value indicating whether the native GemFire Cache Region or Region proxy is exposed
* @return a boolean value indicating whether the native Pivotal GemFire Cache Region or Region proxy is exposed
* to the GemfireCallback code.
*/
public boolean isExposeNativeRegion() {
@@ -473,12 +473,12 @@ public class GemfireTemplate extends GemfireAccessor implements GemfireOperation
}
/**
* Create a close-suppressing proxy for the given GemFire Cache {@link Region}.
* Create a close-suppressing proxy for the given Pivotal GemFire Cache {@link Region}.
* Called by the <code>execute</code> method.
*
* @param <K> the Region key class type.
* @param <V> the Region value class type.
* @param region the GemFire Cache Region to create a proxy for.
* @param region the Pivotal GemFire Cache Region to create a proxy for.
* @return the Region proxy implementing all interfaces implemented by the passed-in Region object.
* @see org.apache.geode.cache.Region#close()
* @see #execute(GemfireCallback, boolean)
@@ -493,7 +493,7 @@ public class GemfireTemplate extends GemfireAccessor implements GemfireOperation
}
/**
* InvocationHandler that suppresses close calls on GemFire Cache Regions.
* InvocationHandler that suppresses close calls on Pivotal GemFire Cache Regions.
*
* @see org.apache.geode.cache.Region#close()
* @see java.lang.reflect.InvocationHandler

View File

@@ -26,7 +26,7 @@ import org.springframework.util.ClassUtils;
/**
* {@link GemfireUtils} is an abstract utility class encapsulating common functionality to access features
* and capabilities of GemFire based on version and other configuration meta-data.
* and capabilities of Pivotal GemFire based on version and other configuration meta-data.
*
* @author John Blum
* @see org.apache.geode.cache.CacheFactory
@@ -42,7 +42,6 @@ public abstract class GemfireUtils extends RegionUtils {
public final static String GEMFIRE_VERSION = apacheGeodeVersion();
public final static String UNKNOWN = "unknown";
/* (non-Javadoc) */
public static String apacheGeodeProductName() {
try {
@@ -53,7 +52,6 @@ public abstract class GemfireUtils extends RegionUtils {
}
}
/* (non-Javadoc) */
public static String apacheGeodeVersion() {
try {
@@ -64,13 +62,11 @@ public abstract class GemfireUtils extends RegionUtils {
}
}
/* (non-Javadoc) */
public static boolean isGemfireVersionGreaterThanEqualTo(double expectedVersion) {
double actualVersion = Double.parseDouble(GEMFIRE_VERSION.substring(0, 3));
return actualVersion >= expectedVersion;
}
/* (non-Javadoc) */
public static boolean isGemfireVersion65OrAbove() {
// expected 'major.minor'
try {
@@ -83,7 +79,6 @@ public abstract class GemfireUtils extends RegionUtils {
}
}
/* (non-Javadoc) */
public static boolean isGemfireVersion7OrAbove() {
try {
return isGemfireVersionGreaterThanEqualTo(7.0);
@@ -95,7 +90,6 @@ public abstract class GemfireUtils extends RegionUtils {
}
}
/* (non-Javadoc) */
public static boolean isGemfireVersion8OrAbove() {
try {

View File

@@ -18,14 +18,14 @@ package org.springframework.data.gemfire;
/**
* The GenericRegionFactoryBean class is an extension of the abstract, base RegionFactoryBean class enabling developers
* to define a GemFire Cache Region with defaults.
* to define a Pivotal GemFire Cache Region with defaults.
*
* The defaults for DataPolicy is NORMAL and Scope is DISTRIBUTED_NO_ACK, effectively creating a "non-replicate",
* Distributed Region.
*
* This class enables developers to create various non-strongly-typed Regions (e.g. PARTITION, REPLICATE) based on
* various combinations of the DataPolicy, Scope and Subscription settings as defined in the Region Types section
* of the GemFire User Guide (see link below). How GemFire Regions receive and distribute entry updates
* of the Pivotal GemFire User Guide (see link below). How Pivotal GemFire Regions receive and distribute entry updates
* is defined in the Storage and Distribution Options section.
*
* Note, it is generally better to define strong-typed Regions (e.g. PARTITION with PartitionedRegionFactoryBean)

View File

@@ -20,7 +20,7 @@ import org.apache.geode.cache.AttributesFactory;
import org.apache.geode.cache.RegionFactory;
/**
* The IndexMaintenanceType enum is a enumerated type of GemFire Index maintenance update options.
* The IndexMaintenanceType enum is a enumerated type of Pivotal GemFire Index maintenance update options.
*
* @author John Blum
* @see org.apache.geode.cache.AttributesFactory#setIndexMaintenanceSynchronous(boolean)
@@ -56,7 +56,7 @@ public enum IndexMaintenancePolicyType {
}
/**
* Sets the GemFire AttributesFactory's 'indexMaintenanceSynchronous' property appropriately based on
* Sets the Pivotal GemFire AttributesFactory's 'indexMaintenanceSynchronous' property appropriately based on
* this IndexMaintenancePolicyType.
*
* @param attributesFactory the AttributesFactory instance on which to set the indexMaintenanceProperty.
@@ -69,7 +69,7 @@ public enum IndexMaintenancePolicyType {
}
/**
* Sets the GemFire RegionFactory's 'indexMaintenanceSynchronous' property appropriately based on
* Sets the Pivotal GemFire RegionFactory's 'indexMaintenanceSynchronous' property appropriately based on
* this IndexMaintenancePolicyType.
*
* @param regionFactory the RegionFactory instance on which to set the indexMaintenanceProperty.

View File

@@ -17,7 +17,7 @@
package org.springframework.data.gemfire;
/**
* The IndexType class is an enumerated type of GemFire Index Types.
* The IndexType class is an enumerated type of Pivotal GemFire Index Types.
*
* @author John Blum
* @see org.apache.geode.cache.query.IndexType
@@ -34,9 +34,9 @@ public enum IndexType {
private final org.apache.geode.cache.query.IndexType gemfireIndexType;
/**
* Constructs an instance of the IndexType enum initialized with the given GemFire IndexType.
* Constructs an instance of the IndexType enum initialized with the given Pivotal GemFire IndexType.
*
* @param gemfireIndexType the corresponding GemFire IndexType
* @param gemfireIndexType the corresponding Pivotal GemFire IndexType
* @see org.apache.geode.cache.query.IndexType
*/
IndexType(final org.apache.geode.cache.query.IndexType gemfireIndexType) {
@@ -77,11 +77,11 @@ public enum IndexType {
}
/**
* Returns an IndexType given the corresponding GemFire IndexType or null if no SDG IndexType
* corresponds to the GemFire IndexType.
* Returns an IndexType given the corresponding Pivotal GemFire IndexType or null if no SDG IndexType
* corresponds to the Pivotal GemFire IndexType.
*
* @param gemfireIndexType the GemFire IndexType.
* @return a IndexType matching the GemFire IndexType or null if the GemFire IndexType does not match
* @param gemfireIndexType the Pivotal GemFire IndexType.
* @return a IndexType matching the Pivotal GemFire IndexType or null if the Pivotal GemFire IndexType does not match
* any IndexType in this enumeration.
* @see org.apache.geode.cache.query.IndexType
*/
@@ -115,9 +115,9 @@ public enum IndexType {
}
/**
* Gets the matching GemFire IndexType for this IndexType enumerated value.
* Gets the matching Pivotal GemFire IndexType for this IndexType enumerated value.
*
* @return the matching GemFire IndexType.
* @return the matching Pivotal GemFire IndexType.
* @see org.apache.geode.cache.query.IndexType
*/
public org.apache.geode.cache.query.IndexType getGemfireIndexType() {

View File

@@ -21,7 +21,7 @@ import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterS
/**
* The InterestPolicyConverter class is a Spring Converter implementation and Java PropertyEditor handling
* the conversion between Strings and GemFire InterestPolicy values.
* the conversion between Strings and Pivotal GemFire InterestPolicy values.
*
* @author John Blum
* @see org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport
@@ -32,11 +32,11 @@ import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterS
public class InterestPolicyConverter extends AbstractPropertyEditorConverterSupport<InterestPolicy> {
/**
* Converts the given String into a GemFire InterestPolicy value.
* Converts the given String into a Pivotal GemFire InterestPolicy value.
*
* @param source the String value to convert into a GemFire InterestPolicy value.
* @return a GemFire InterestPolicy value for the given String description of the GemFire InterestPolicy
* @throws java.lang.IllegalArgumentException if the String is not a valid GemFire InterestPolicy.
* @param source the String value to convert into a Pivotal GemFire InterestPolicy value.
* @return a Pivotal GemFire InterestPolicy value for the given String description of the Pivotal GemFire InterestPolicy
* @throws java.lang.IllegalArgumentException if the String is not a valid Pivotal GemFire InterestPolicy.
* @see org.springframework.data.gemfire.InterestPolicyType#getInterestPolicy(InterestPolicyType)
* @see org.springframework.data.gemfire.InterestPolicyType#valueOfIgnoreCase(String)
* @see #assertConverted(String, Object, Class)

View File

@@ -18,7 +18,7 @@ package org.springframework.data.gemfire;
import org.apache.geode.cache.InterestPolicy;
/**
* The InterestPolicyType enum is an enumeration of all the GemFire Subscription, InterestPolicy values.
* The InterestPolicyType enum is an enumeration of all the Pivotal GemFire Subscription, InterestPolicy values.
*
* @author Lyndon Adams
* @author John Blum
@@ -27,6 +27,7 @@ import org.apache.geode.cache.InterestPolicy;
*/
@SuppressWarnings("unused")
public enum InterestPolicyType {
ALL(InterestPolicy.ALL),
CACHE_CONTENT(InterestPolicy.CACHE_CONTENT);
@@ -35,9 +36,9 @@ public enum InterestPolicyType {
private final InterestPolicy interestPolicy;
/**
* Constructs an instance of the SubscriptionType enum initialized with the matching GemFire InterestPolicy.
* Constructs an instance of the SubscriptionType enum initialized with the matching Pivotal GemFire InterestPolicy.
*
* @param interestPolicy a GemFire InterestPolicy corresponding to this SubscriptionType.
* @param interestPolicy a Pivotal GemFire InterestPolicy corresponding to this SubscriptionType.
* @see org.apache.geode.cache.InterestPolicy
*/
InterestPolicyType(final InterestPolicy interestPolicy) {
@@ -45,11 +46,13 @@ public enum InterestPolicyType {
}
/**
* Null-safe operation to extract the GemFire InterestPolicy from the InterPolicyType enumerated value.
* Null-safe operation to extract the Pivotal GemFire {@link InterestPolicy}
* from the {@link InterestPolicyType} enumerated value.
*
* @param interestPolicyType the InterestPolicyType enum from which to extract GemFire's InterestPolicy
* @return a GemFire InterestPolicy for the given InterestPolicyType enumerated value
* or null if InterestPolicyType is null.
* @param interestPolicyType the {@link InterestPolicyType} enum from which to extract
* Pivotal GemFire's {@link InterestPolicy}.
* @return a Pivotal GemFire {@link InterestPolicy} for the given {@link InterestPolicyType} enumerated value
* or {@literal null} if {@link InterestPolicyType} is {@literal null}.
* @see org.apache.geode.cache.InterestPolicy
*/
public static InterestPolicy getInterestPolicy(final InterestPolicyType interestPolicyType) {
@@ -57,10 +60,10 @@ public enum InterestPolicyType {
}
/**
* Returns a SubscriptionType enumerated value for the given GemFire InterestPolicy.
* Returns a SubscriptionType enumerated value for the given Pivotal GemFire InterestPolicy.
*
* @param interestPolicy the GemFire InterestPolicy used to lookup and match a SubscriptionType.
* @return a SubscriptionType enumerated value matching the given GemFire InterestPolicy
* @param interestPolicy the Pivotal GemFire InterestPolicy used to lookup and match a SubscriptionType.
* @return a SubscriptionType enumerated value matching the given Pivotal GemFire InterestPolicy
* or null if no matching value was found.
* @see org.apache.geode.cache.InterestPolicy
* @see #getInterestPolicy()
@@ -95,13 +98,12 @@ public enum InterestPolicyType {
}
/**
* Returns the GemFire InterestPolicy corresponding to this SubscriptionType enumerated value.
* Returns the Pivotal GemFire InterestPolicy corresponding to this SubscriptionType enumerated value.
*
* @return the GemFire InterestPolicy corresponding to this SubscriptionType.
* @return the Pivotal GemFire InterestPolicy corresponding to this SubscriptionType.
* @see org.apache.geode.cache.InterestPolicy
*/
public InterestPolicy getInterestPolicy() {
return interestPolicy;
}
}

View File

@@ -36,10 +36,10 @@ public enum JndiDataSourceType {
private final String name;
/**
* Constructs an instance of the JndiDataSourceType enum initialized with the specified name used by GemFire to
* Constructs an instance of the JndiDataSourceType enum initialized with the specified name used by Pivotal GemFire to
* specify supported JNDI DataSource implementations.
*
* @param name the GemFire named JNDI DataSource implementation.
* @param name the Pivotal GemFire named JNDI DataSource implementation.
*/
JndiDataSourceType(final String name) {
Assert.hasText(name, "The JNDI DataSource Type 'name' must be specified!");
@@ -47,11 +47,11 @@ public enum JndiDataSourceType {
}
/**
* Returns a JndiDataSourceType enumerated value based on the GemFire preferred name for the supported JNDI,
* Returns a JndiDataSourceType enumerated value based on the Pivotal GemFire preferred name for the supported JNDI,
* DataSource implementation, ignoring case and all extra leading/trailing whitespace.
*
* @param name the GemFire named JNDI DataSource implementation.
* @return the JndiDataSourceType enumerated value matching the given GemFire name used for the supported JNDI,
* @param name the Pivotal GemFire named JNDI DataSource implementation.
* @return the JndiDataSourceType enumerated value matching the given Pivotal GemFire name used for the supported JNDI,
* DataSource implementation, or null if not match was found.
* @see #values()
* @see #isMatch(JndiDataSourceType, String)
@@ -67,11 +67,11 @@ public enum JndiDataSourceType {
}
/**
* Determines whether the specified JndiDataSourceType enum and the given, supported GemFire 'named',
* Determines whether the specified JndiDataSourceType enum and the given, supported Pivotal GemFire 'named',
* JNDI DataSource implementation are a match.
*
* @param jndiDataSourceType the given JndiDataSourceType enum used in the match.
* @param name the specified GemFire "named" JNDI DataSource implementation.
* @param name the specified Pivotal GemFire "named" JNDI DataSource implementation.
* @return a boolean value indicating whether the given JndiDataSourceType enumerated value matched the given name.
* @see java.lang.String#equalsIgnoreCase(String)
* @see org.springframework.util.StringUtils#trimWhitespace(String)
@@ -83,16 +83,16 @@ public enum JndiDataSourceType {
}
/**
* Gets the GemFire name of the support JNDI DataSource implementation type.
* Gets the Pivotal GemFire name of the support JNDI DataSource implementation type.
*
* @return the GemFire named JNDI DataSource implementation.
* @return the Pivotal GemFire named JNDI DataSource implementation.
*/
public String getName() {
return name;
}
/**
* Returns a String describing this JNDI DataSource implementation based on the GemFire supported names.
* Returns a String describing this JNDI DataSource implementation based on the Pivotal GemFire supported names.
*
* @return a String description for this JNDI DataSource (implementation) type.
*/

View File

@@ -67,13 +67,13 @@ public class LocalRegionFactoryBean<K, V> extends RegionFactoryBean<K, V> {
}
/**
* Resolves the Data Policy used by this "local" GemFire Region (i.e. locally Scoped; Scope.LOCAL) based on the
* Resolves the Data Policy used by this "local" Pivotal GemFire Region (i.e. locally Scoped; Scope.LOCAL) based on the
* enumerated value from org.apache.geode.cache.RegionShortcuts (LOCAL, LOCAL_PERSISTENT, LOCAL_HEAP_LRU,
* LOCAL_OVERFLOW, and LOCAL_PERSISTENT_OVERFLOW), but without consideration of the Eviction settings.
*
* @param regionFactory the GemFire RegionFactory used to created the Local Region.
* @param regionFactory the Pivotal GemFire RegionFactory used to created the Local Region.
* @param persistent a boolean value indicating whether the Local Region should persist it's data.
* @param dataPolicy requested Data Policy as set by the user in the Spring GemFire configuration meta-data.
* @param dataPolicy requested Data Policy as set by the user in the Spring Pivotal GemFire configuration meta-data.
* @see org.apache.geode.cache.DataPolicy
* @see org.apache.geode.cache.RegionFactory
* @see org.apache.geode.cache.RegionShortcut

View File

@@ -31,17 +31,17 @@ public class PartitionedRegionFactoryBean<K, V> extends RegionFactoryBean<K, V>
// First, verify the GemFire version is 6.5 or Higher when Persistence is specified...
Assert.isTrue(!DataPolicy.PERSISTENT_PARTITION.equals(dataPolicy) || GemfireUtils.isGemfireVersion65OrAbove(),
String.format("Persistent PARTITION Regions can only be used from GemFire 6.5 onwards; current version is [%s].",
String.format("Persistent PARTITION Regions can only be used from Pivotal GemFire 6.5 onwards; current version is [%s]",
CacheFactory.getVersion()));
if (dataPolicy == null) {
dataPolicy = (isPersistent() ? DataPolicy.PERSISTENT_PARTITION : DataPolicy.PARTITION);
}
else {
// Validate that the user-defined Data Policy matches the appropriate Spring GemFire XML namespace
// Validate that the user-defined Data Policy matches the appropriate Spring Pivotal GemFire XML namespace
// configuration meta-data element for Region (i.e. <gfe:partitioned-region .../>)!
Assert.isTrue(dataPolicy.withPartitioning(), String.format(
"Data Policy '%1$s' is not supported in Partitioned Regions.", dataPolicy));
"Data Policy [%s] is not supported in Partitioned Regions", dataPolicy));
}
// Validate the data-policy and persistent attributes are compatible when specified!

View File

@@ -401,7 +401,7 @@ public abstract class RegionFactoryBean<K, V> extends RegionLookupFactoryBean<K,
*
* @param <K> the Class type fo the Region key.
* @param <V> the Class type of the Region value.
* @param regionFactory the GemFire RegionFactory used to configure and create the Region that is the product
* @param regionFactory the Pivotal GemFire RegionFactory used to configure and create the Region that is the product
* of this RegionFactoryBean.
* @param regionAttributes the RegionAttributes containing the Region configuration settings to merge to the
* RegionFactory.
@@ -512,7 +512,7 @@ public abstract class RegionFactoryBean<K, V> extends RegionLookupFactoryBean<K,
*
* This method is not part of the RegionFactoryBean API and is strictly used for testing purposes!
*
* NOTE unfortunately, must resort to using a GemFire internal class, ugh!
* NOTE unfortunately, must resort to using a Pivotal GemFire internal class, ugh!
*
* @see org.apache.geode.internal.cache.UserSpecifiedRegionAttributes#hasEvictionAttributes
*/
@@ -573,6 +573,7 @@ public abstract class RegionFactoryBean<K, V> extends RegionLookupFactoryBean<K,
}
/**
<<<<<<< HEAD
* Validates that the settings for Data Policy and the 'persistent' attribute in &lt;gfe:*-region&gt; elements
* are compatible.
*
@@ -600,6 +601,10 @@ public abstract class RegionFactoryBean<K, V> extends RegionLookupFactoryBean<K,
>>>>>>> c22ebe6... DATAGEODE-12 - Introduce Spring Configurers to flexibly alter Spring Data GemFire configuration when using Annotation config.
* Validates and sets the Data Policy on the RegionFactory used to create and configure the Region from this
* FactoryBean.
=======
* Validates and sets the {@link DataPolicy} on the {@link RegionFactory} used to create and configure
* the {@link Region} from this {@link FactoryBean}.
>>>>>>> 12126a1... SGF-732 - Change branding from Spring Data GemFire to Spring Data for Pivotal GemFire.
*
* @param regionFactory the RegionFactory used by this FactoryBean to create and configure the Region.
* @param persistent a boolean value indicating whether the Region should be persistent and persist it's
@@ -625,9 +630,9 @@ public abstract class RegionFactoryBean<K, V> extends RegionLookupFactoryBean<K,
* Validates the configured Data Policy and may override it, taking into account the 'persistent' attribute
* and constraints for the Region type.
*
* @param regionFactory the GemFire RegionFactory used to create the desired Region.
* @param regionFactory the Pivotal GemFire RegionFactory used to create the desired Region.
* @param persistent a boolean value indicating whether the Region should persist it's data to disk.
* @param dataPolicy requested Data Policy as set by the user in the Spring GemFire configuration meta-data.
* @param dataPolicy requested Data Policy as set by the user in the Spring Pivotal GemFire configuration meta-data.
* @see org.apache.geode.cache.DataPolicy
* @see org.apache.geode.cache.RegionFactory
*/
@@ -785,7 +790,7 @@ public abstract class RegionFactoryBean<K, V> extends RegionLookupFactoryBean<K,
/**
* Sets the DataPolicy of the Region.
*
* @param dataPolicy the GemFire DataPolicy to use when configuring the Region.
* @param dataPolicy the Pivotal GemFire DataPolicy to use when configuring the Region.
* @since 1.4.0
*/
public void setDataPolicy(DataPolicy dataPolicy) {

View File

@@ -208,17 +208,14 @@ public abstract class RegionLookupFactoryBean<K, V> extends AbstractFactoryBeanS
this.cache = cache;
}
/* (non-Javadoc) */
boolean isLookupEnabled() {
return Boolean.TRUE.equals(getLookupEnabled());
}
/* (non-Javadoc) */
public void setLookupEnabled(Boolean lookupEnabled) {
this.lookupEnabled = lookupEnabled;
}
/* (non-Javadoc) */
public Boolean getLookupEnabled() {
return this.lookupEnabled;
}
@@ -236,7 +233,7 @@ public abstract class RegionLookupFactoryBean<K, V> extends AbstractFactoryBeanS
}
/**
* Sets a reference to the parent {@link Region} to indicated this {@link FactoryBean} represents a GemFire cache
* Sets a reference to the parent {@link Region} to indicated this {@link FactoryBean} represents a Pivotal GemFire cache
* {@link Region Sub-Region}.
*
* @param parent reference to the parent {@link Region}.
@@ -247,7 +244,7 @@ public abstract class RegionLookupFactoryBean<K, V> extends AbstractFactoryBeanS
}
/**
* Returns a reference to the parent {@link Region} indicating this {@link FactoryBean} represents a GemFire cache
* Returns a reference to the parent {@link Region} indicating this {@link FactoryBean} represents a Pivotal GemFire cache
* {@link Region Sub-Region}.
*
* @return a reference to the parent {@link Region} or {@literal null} if this {@link Region}

View File

@@ -21,7 +21,7 @@ import org.springframework.core.convert.converter.Converter;
/**
* The RegionShortcutConverter class is a Spring Converter implementation converting String value Region Shortcut
* representations into actual GemFire RegionShortcut enumerated values.
* representations into actual Pivotal GemFire RegionShortcut enumerated values.
*
* @author John Blum
* @see org.springframework.core.convert.converter.Converter

View File

@@ -21,10 +21,11 @@ import org.apache.geode.cache.RegionShortcut;
import org.springframework.util.ObjectUtils;
/**
* The {@link RegionShortcutWrapper} enum is a Java enumerated type that wraps GemFire's {@link RegionShortcut RegionShortcuts}
* with Spring Data GemFire {@link RegionShortcutWrapper} enumerated values.
* The {@link RegionShortcutWrapper} enum is a Java enumerated type that wraps Pivotal GemFire's
* {@link RegionShortcut RegionShortcuts} with SDG {@link RegionShortcutWrapper} enumerated values.
*
* @author John Blum
* @see org.apache.geode.cache.DataPolicy
* @see org.apache.geode.cache.RegionShortcut
* @since 1.4.0
*/

View File

@@ -34,7 +34,7 @@ public class ReplicatedRegionFactoryBean<K, V> extends RegionFactoryBean<K, V> {
dataPolicy = DataPolicy.EMPTY;
}
else {
// Validate that the user-defined Data Policy matches the appropriate Spring GemFire XML namespace
// Validate that the user-defined Data Policy matches the appropriate Spring Pivotal GemFire XML namespace
// configuration meta-data element for the Region (i.e. <gfe:replicated-region .../>)!
Assert.isTrue(dataPolicy.withReplication(), String.format(
"Data Policy '%1$s' is not supported in Replicated Regions.", dataPolicy));

View File

@@ -21,7 +21,7 @@ import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterS
/**
* The ScopeConverter class is a Spring Converter and JavaBeans PropertyEditor that converts Strings
* into GemFire Scope constant values.
* into Pivotal GemFire Scope constant values.
*
* @author John Blum
* @see org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport
@@ -32,11 +32,11 @@ import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterS
public class ScopeConverter extends AbstractPropertyEditorConverterSupport<Scope> {
/**
* Converts the given String source into an instance of GemFire Scope.
* Converts the given String source into an instance of Pivotal GemFire Scope.
*
* @param source the String to convert into a GemFire Scope.
* @return a GemFire Scope for the given String.
* @throws java.lang.IllegalArgumentException if the String is not a valid GemFire Scope.
* @param source the String to convert into a Pivotal GemFire Scope.
* @return a Pivotal GemFire Scope for the given String.
* @throws java.lang.IllegalArgumentException if the String is not a valid Pivotal GemFire Scope.
* @see org.springframework.data.gemfire.ScopeType#getScope(ScopeType)
* @see org.springframework.data.gemfire.ScopeType#valueOfIgnoreCase(String)
* @see org.apache.geode.cache.Scope#fromString(String)

View File

@@ -20,7 +20,7 @@ import org.apache.geode.cache.Scope;
import org.springframework.util.StringUtils;
/**
* The ScopeType enum is an enumeration of GemFire Scopes.
* The ScopeType enum is an enumeration of Pivotal GemFire Scopes.
*
* @author John Blum
* @see org.apache.geode.cache.Scope
@@ -36,9 +36,9 @@ public enum ScopeType {
private final Scope gemfireScope;
/**
* Constructs an instance of the ScopeType initialized with a matching GemFire Scope.
* Constructs an instance of the ScopeType initialized with a matching Pivotal GemFire Scope.
*
* @param gemfireScope the GemFire Scope paired with this enumerated value.
* @param gemfireScope the Pivotal GemFire Scope paired with this enumerated value.
* @see org.apache.geode.cache.Scope
*/
ScopeType(final Scope gemfireScope) {
@@ -46,11 +46,11 @@ public enum ScopeType {
}
/**
* Null-safe operation to extract the GemFire Scope from the given ScopeType enum value, or null if the provided
* Null-safe operation to extract the Pivotal GemFire Scope from the given ScopeType enum value, or null if the provided
* scopeType is null.
*
* @param scopeType the ScopeType enumerated value from which to extract the GemFire Scope.
* @return the paired GemFire Scope from the given ScopeType or null if scopeType is null.
* @param scopeType the ScopeType enumerated value from which to extract the Pivotal GemFire Scope.
* @return the paired Pivotal GemFire Scope from the given ScopeType or null if scopeType is null.
* @see org.apache.geode.cache.Scope
* @see #getScope()
*/
@@ -59,10 +59,10 @@ public enum ScopeType {
}
/**
* Returns a ScopeType enumerated value for the given a GemFire Scope.
* Returns a ScopeType enumerated value for the given a Pivotal GemFire Scope.
*
* @param scope the GemFire Scope used to lookup and match the appropriate ScopeType.
* @return a ScopeType for the given GemFire Scope or null if no match was found.
* @param scope the Pivotal GemFire Scope used to lookup and match the appropriate ScopeType.
* @return a ScopeType for the given Pivotal GemFire Scope or null if no match was found.
* @see org.apache.geode.cache.Scope
* @see #getScope()
* @see #values()
@@ -78,10 +78,10 @@ public enum ScopeType {
}
/**
* Returns a ScopeType enumerated value given the case-insensitive name of the GemFire Scope.
* Returns a ScopeType enumerated value given the case-insensitive name of the Pivotal GemFire Scope.
*
* @param name a String name describing the ScopeType enum value.
* @return a ScopeType for the given case-insensitive, named GemFire Scope.
* @return a ScopeType for the given case-insensitive, named Pivotal GemFire Scope.
* @see java.lang.String#equalsIgnoreCase(String)
* @see #values()
* @see #name()
@@ -112,9 +112,9 @@ public enum ScopeType {
}
/**
* Gets the matching GemFire Scope for this enumerated value.
* Gets the matching Pivotal GemFire Scope for this enumerated value.
*
* @return a GemFire Scope for this enumerated value.
* @return a Pivotal GemFire Scope for this enumerated value.
* @see org.apache.geode.cache.Scope
*/
public Scope getScope() {

View File

@@ -22,7 +22,7 @@ import org.springframework.beans.factory.InitializingBean;
/**
* The SubscriptionAttributesFactoryBean class is a Spring FactoryBean used for defining and constructing
* a GemFire SubscriptionAttributes object, which determines the Subscription policy used by Regions to
* a Pivotal GemFire SubscriptionAttributes object, which determines the Subscription policy used by Regions to
* declared their data interests.
*
* @author Lyndon Adams
@@ -76,10 +76,10 @@ public class SubscriptionAttributesFactoryBean implements FactoryBean<Subscripti
}
/**
* Sets GemFire's InterestPolicy specified on the SubscriptionAttributes in order to define/declare
* the data interests and distribution of changes.
* Sets Pivotal GemFire's {@link InterestPolicy} specified on the {@link SubscriptionAttributes} in order to
* define/declare the data interests and distribution of changes.
*
* @param interestPolicy the GemFire InterestsPolicy to set for Subscription.
* @param interestPolicy the Pivotal GemFire {@link InterestPolicy} to set for Subscription.
* @see org.apache.geode.cache.InterestPolicy
* @see org.apache.geode.cache.SubscriptionAttributes#SubscriptionAttributes(org.apache.geode.cache.InterestPolicy)
*/
@@ -88,10 +88,10 @@ public class SubscriptionAttributesFactoryBean implements FactoryBean<Subscripti
}
/**
* Gets GemFire's InterestPolicy specified on the SubscriptionAttributes which defines data interests
* and distribution of changes.
* Gets Pivotal GemFire's {@link InterestPolicy} specified on the {@link SubscriptionAttributes}, which defines
* data interests and distribution of changes.
*
* @return the GemFire InterestsPolicy set for Subscription.
* @return the Pivotal GemFire {@link InterestPolicy} set for Subscription.
* @see org.apache.geode.cache.InterestPolicy
* @see org.apache.geode.cache.SubscriptionAttributes#getInterestPolicy()
*/
@@ -99,16 +99,13 @@ public class SubscriptionAttributesFactoryBean implements FactoryBean<Subscripti
return (interestPolicy != null ? interestPolicy : InterestPolicy.DEFAULT);
}
/* non-Javadoc */
@Deprecated
public void setPolicy(InterestPolicy policy) {
setInterestPolicy(policy);
}
/* non-Javadoc */
@Deprecated
public InterestPolicy getPolicy() {
return getInterestPolicy();
}
}

View File

@@ -27,9 +27,9 @@ import org.apache.geode.cache.TimeoutException;
import org.springframework.util.Assert;
/**
* The {@link CallableCacheLoaderAdapter} class is a {@link Callable} and GemFire {@link CacheLoader} implementation
* The {@link CallableCacheLoaderAdapter} class is a {@link Callable} and Pivotal GemFire {@link CacheLoader} implementation
* that adapts the {@link Callable} interface into an instance of the {@link CacheLoader} interface. This class is
* useful in situations where GemFire developers have several {@link CacheLoader} implementations that they wish to
* useful in situations where Pivotal GemFire developers have several {@link CacheLoader} implementations that they wish to
* use with Spring's Cache Abstraction.
*
* @author John Blum

View File

@@ -25,7 +25,7 @@ import org.springframework.cache.support.SimpleValueWrapper;
import org.springframework.util.Assert;
/**
* Spring Framework {@link Cache} implementation backed by a GemFire {@link Region}.
* Spring Framework {@link Cache} implementation backed by a Pivotal GemFire {@link Region}.
*
* @author Costin Leau
* @author John Blum
@@ -38,11 +38,11 @@ public class GemfireCache implements Cache {
private final Region region;
/**
* Wraps a GemFire {@link Region} in an instance of {@link GemfireCache} to adapt the GemFire {@link Region}
* Wraps a Pivotal GemFire {@link Region} in an instance of {@link GemfireCache} to adapt the Pivotal GemFire {@link Region}
* to function as a Spring {@link Cache} in Spring's caching infrastructure.
*
* @param region GemFire {@link Region} to wrap.
* @return an instance of {@link GemfireCache} backed by the provided GemFire {@link Region}.
* @param region Pivotal GemFire {@link Region} to wrap.
* @return an instance of {@link GemfireCache} backed by the provided Pivotal GemFire {@link Region}.
* @see org.apache.geode.cache.Region
* @see org.springframework.cache.Cache
* @see #GemfireCache(Region)
@@ -52,22 +52,22 @@ public class GemfireCache implements Cache {
}
/**
* Constructs an instance of {@link GemFireCache} initialized with the given GemFire {@link Region}.
* Constructs an instance of {@link GemFireCache} initialized with the given Pivotal GemFire {@link Region}.
* The {@link Region} will function as the backing store and implementation for
* the Spring {@link Cache} interface.
*
* @param region GemFire {@link Region} backing the Spring {@link Cache}.
* @param region Pivotal GemFire {@link Region} backing the Spring {@link Cache}.
* @throws IllegalArgumentException if {@link Region} is null.
*/
public GemfireCache(Region<?, ?> region) {
Assert.notNull(region, "GemFire Region must not be null");
Assert.notNull(region, "Region must not be null");
this.region = region;
}
/**
* Returns the GemFire {@link Region} used as the implementation for this Spring {@link Cache}.
* Returns the Pivotal GemFire {@link Region} used as the implementation for this Spring {@link Cache}.
*
* @return the GemFire {@link Region} used as the implementation for this Spring {@link Cache}.
* @return the Pivotal GemFire {@link Region} used as the implementation for this Spring {@link Cache}.
* @see org.apache.geode.cache.Region
*/
public Region getNativeCache() {

View File

@@ -29,10 +29,10 @@ import org.springframework.cache.support.AbstractCacheManager;
import org.springframework.util.Assert;
/**
* Core Spring Framework {@link CacheManager} implementation backed by a GemFire cache instance
* Core Spring Framework {@link CacheManager} implementation backed by a Pivotal GemFire cache instance
* (either a client or peer cache).
*
* Automatically discovers available caches (or GemFire {@link Region Regions}) when a cache for a given name
* Automatically discovers available caches (or Pivotal GemFire {@link Region Regions}) when a cache for a given name
* is missing and dynamic cache lookup/creation is enabled.
*
* @author Costin Leau
@@ -55,17 +55,16 @@ public class GemfireCacheManager extends AbstractCacheManager {
private Set<String> cacheNames;
/* (non-Javadoc) */
@SuppressWarnings("all")
<T extends GemFireCache> T assertGemFireCacheAvailable(T gemfireCache) {
Assert.state(gemfireCache != null, "A GemFire cache instance is required");
Assert.state(!gemfireCache.isClosed(), String.format("GemFire cache [%s] has been closed",
Assert.state(gemfireCache != null, "A cache instance is required");
Assert.state(!gemfireCache.isClosed(), String.format("The cache [%s] has been closed",
gemfireCache.getName()));
return gemfireCache;
}
/* (non-Javadoc) */
@SuppressWarnings("all")
Region<?, ?> assertGemFireRegionAvailable(Region<?, ?> region, String cacheName) {
Assert.state(region != null, String.format("No Region for cache name [%s] was found", cacheName));
@@ -75,23 +74,23 @@ public class GemfireCacheManager extends AbstractCacheManager {
}
/**
* Loads all configured GemFire {@link Region Regions} that will be used by this {@link CacheManager}.
* Loads all configured Pivotal GemFire {@link Region Regions} that will be used by this {@link CacheManager}.
*
* Any GemFire {@link Region Regions} configured with the {@link #regions} property will take precedence over
* any configured {@link #cacheNames}. If no GemFire {@link Region Regions} were configured, then any
* {@link #cacheNames} that were specified will be used to lookup existing GemFire {@link Region Regions}
* Any Pivotal GemFire {@link Region Regions} configured with the {@link #regions} property will take precedence over
* any configured {@link #cacheNames}. If no Pivotal GemFire {@link Region Regions} were configured, then any
* {@link #cacheNames} that were specified will be used to lookup existing Pivotal GemFire {@link Region Regions}
* to function as Spring {@link Cache Caches}in Spring's caching infrastructure.
*
* However, if neither {@link #regions} nor {@link #cacheNames} were specified, then all defined GemFire
* {@link Region Regions} declared in the Spring application context, as determined by
* {@link GemFireCache#rootRegions()}, will be used as Spring {@link Cache Caches}, and this {@link CacheManager}
* will allow any dynamically created GemFire {@link Region Regions} at runtime to be found and used as a
* will allow any dynamically created Pivotal GemFire {@link Region Regions} at runtime to be found and used as a
* Spring {@link Cache} as well.
*
* @return a {@link Collection} of GemFire {@link Region Regions} used by this {@link CacheManager}
* @return a {@link Collection} of Pivotal GemFire {@link Region Regions} used by this {@link CacheManager}
* to function as {@link Cache Caches} in Spring's caching infrastructure.
* @throws IllegalStateException if a GemFire cache instance was not provided, the provided GemFire cache instance
* has been closed, no GemFire {@link Region} could be found for a given cache name, or the GemFire {@link Region}
* @throws IllegalStateException if a Pivotal GemFire cache instance was not provided, the provided Pivotal GemFire cache instance
* has been closed, no Pivotal GemFire {@link Region} could be found for a given cache name, or the Pivotal GemFire {@link Region}
* for the given cache name has been destroyed.
* @see org.springframework.cache.Cache
*/
@@ -108,8 +107,8 @@ public class GemfireCacheManager extends AbstractCacheManager {
return caches;
}
/* (non-Javadoc) */
Set<Region<?, ?>> resolveRegions(GemFireCache gemfireCache, Set<Region<?, ?>> regions, Set<String> cacheNames) {
if (isSet(regions)) {
dynamic.set(false);
return regions;
@@ -130,16 +129,15 @@ public class GemfireCacheManager extends AbstractCacheManager {
}
}
/* (non-Javadoc) */
boolean isSet(Iterable<?> collection) {
return (collection != null && collection.iterator().hasNext());
}
/**
* Constructs a new instance of {@link GemfireCache} initialized with the given GemFire {@link Region}.
* Constructs a new instance of {@link GemfireCache} initialized with the given Pivotal GemFire {@link Region}.
*
* @param region GemFire {@link Region} to wrap (adapt).
* @return an instance of {@link GemfireCache} initialized with the given GemFire {@link Region}.
* @param region Pivotal GemFire {@link Region} to wrap (adapt).
* @return an instance of {@link GemfireCache} initialized with the given Pivotal GemFire {@link Region}.
* @see GemfireCache
* @see org.apache.geode.cache.Region
*/
@@ -147,7 +145,6 @@ public class GemfireCacheManager extends AbstractCacheManager {
return GemfireCache.wrap(region);
}
/* (non-Javadoc) */
Region<?, ?> regionFor(GemFireCache gemfireCache, String cacheName) {
return assertGemFireRegionAvailable(assertGemFireCacheAvailable(gemfireCache).getRegion(cacheName), cacheName);
}
@@ -168,9 +165,10 @@ public class GemfireCacheManager extends AbstractCacheManager {
*/
@Override
protected Cache getMissingCache(String name) {
Cache cache = super.getMissingCache(name);
return (cache != null ? cache : (isDynamic() ? newGemfireCache(regionFor(this.gemfireCache, name)) : null));
return cache != null ? cache : (isDynamic() ? newGemfireCache(regionFor(this.gemfireCache, name)) : null);
}
/**
@@ -183,14 +181,14 @@ public class GemfireCacheManager extends AbstractCacheManager {
}
/**
* Sets the GemFire cache instance backing this {@link CacheManager}.
* Sets the Pivotal GemFire cache instance backing this {@link CacheManager}.
*
* When set, if neither {@link Region Regions} nor {@code cacheNames} were specified, then this {@link CacheManager}
* is capable of creating Spring {@link Cache Caches} backed by existing GemFire {@link Region Regions} used by
* is capable of creating Spring {@link Cache Caches} backed by existing Pivotal GemFire {@link Region Regions} used by
* the application at runtime. However, in order to dynamically create Spring {@link Cache Caches} a reference to
* an open GemFire cache instance must be set.
* an open Pivotal GemFire cache instance must be set.
*
* @param gemfireCache the GemFire cache instance used by this {@link CacheManager}
* @param gemfireCache the Pivotal GemFire cache instance used by this {@link CacheManager}
* to manage Spring {@link Cache Caches}.
* @see org.apache.geode.cache.GemFireCache
*/
@@ -212,7 +210,7 @@ public class GemfireCacheManager extends AbstractCacheManager {
* Sets the names of all Spring {@link Cache Caches} that will be used in the application.
*
* When set, this disables the dynamic capability of this {@link CacheManager} to create Spring {@link Cache Caches}
* at runtime by dynamically looking up existing {@link Region Regions} from the GemFire cache instance.
* at runtime by dynamically looking up existing {@link Region Regions} from the Pivotal GemFire cache instance.
*
* @param cacheNames {@link Set} of cache names that will be used in the application.
* @see java.util.Set
@@ -222,13 +220,13 @@ public class GemfireCacheManager extends AbstractCacheManager {
}
/**
* Explicitly sets the GemFire {@link Region Regions} to be used as Spring {@link Cache Caches}
* Explicitly sets the Pivotal GemFire {@link Region Regions} to be used as Spring {@link Cache Caches}
* in the application.
*
* When set, this disables the dynamic capability of this {@link CacheManager} to create Spring {@link Cache Caches}
* at runtime by dynamically looking up existing {@link Region Regions} from the GemFire cache instance.
* at runtime by dynamically looking up existing {@link Region Regions} from the Pivotal GemFire cache instance.
*
* @param regions {@link Set} of GemFire {@link Region Regions} used by this {@link CacheManager}
* @param regions {@link Set} of Pivotal GemFire {@link Region Regions} used by this {@link CacheManager}
* as Spring {@link Cache Caches}.
* @see org.apache.geode.cache.Region
*/
@@ -237,10 +235,10 @@ public class GemfireCacheManager extends AbstractCacheManager {
}
/**
* Returns the set of GemFire {@link Region Regions} used explicitly as Spring {@link Cache Caches}
* Returns the set of Pivotal GemFire {@link Region Regions} used explicitly as Spring {@link Cache Caches}
* in Spring's caching infrastructure.
*
* @return the set of GemFire {@link Region Regions} functioning as Spring {@link Cache Caches}
* @return the set of Pivotal GemFire {@link Region Regions} functioning as Spring {@link Cache Caches}
* in Spring's caching infrastructure
* @see org.apache.geode.cache.Region
*/

View File

@@ -27,8 +27,8 @@ import org.springframework.data.gemfire.cache.GemfireCacheManager;
* used to configure Pivotal GemFire or Apache Geode as the caching provider in Spring's Cache Abstraction.
*
* This {@link Configuration @Configuration} class is specifically responsible for declaring and registering
* Spring Data GemFire/Geode's {@link GemfireCacheManager} implementation to properly enable either Pivotal GemFire
* or Apache Geode as the caching provider used with Springs Cache Abstraction.
* SDG {@link GemfireCacheManager} implementation to properly enable either Pivotal GemFire or Apache Geode
* as the caching provider used with Springs Cache Abstraction.
*
* Additionally, this Spring {@link Configuration @Configuration} class also enables the Spring Cache Abstraction
* by declaring Spring's {@link EnableCaching} annotation for the user extending or importing this class using

View File

@@ -504,7 +504,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Set the GemFire System property 'durable-client-id' to indicate to the server that this client is durable.
* Set the Pivotal GemFire System property 'durable-client-id' to indicate to the server that this client is durable.
*
* @param durableClientId a String value indicating the durable client id.
*/
@@ -513,7 +513,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Gets the value of the GemFire System property 'durable-client-id' indicating to the server whether
* Gets the value of the Pivotal GemFire System property 'durable-client-id' indicating to the server whether
* this client is durable.
*
* @return a String value indicating the durable client id.
@@ -523,7 +523,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Set the GemFire System property 'durable-client-timeout' indicating to the server how long to track events
* Set the Pivotal GemFire System property 'durable-client-timeout' indicating to the server how long to track events
* for the durable client when disconnected.
*
* @param durableClientTimeout an Integer value indicating the timeout in seconds for the server to keep
@@ -534,7 +534,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Get the value of the GemFire System property 'durable-client-timeout' indicating to the server how long
* Get the value of the Pivotal GemFire System property 'durable-client-timeout' indicating to the server how long
* to track events for the durable client when disconnected.
*
* @return an Integer value indicating the timeout in seconds for the server to keep
@@ -667,10 +667,10 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Sets the {@link Pool} used by this cache client to obtain connections to the GemFire cluster.
* Sets the {@link Pool} used by this cache client to obtain connections to the Pivotal GemFire cluster.
*
* @param pool the GemFire {@link Pool} used by this {@link ClientCache} to obtain connections
* to the GemFire cluster.
* @param pool the Pivotal GemFire {@link Pool} used by this {@link ClientCache} to obtain connections
* to the Pivotal GemFire cluster.
* @throws IllegalArgumentException if the {@link Pool} is null.
*/
public void setPool(Pool pool) {
@@ -678,19 +678,19 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Gets the {@link Pool} used by this cache client to obtain connections to the GemFire cluster.
* Gets the {@link Pool} used by this cache client to obtain connections to the Pivotal GemFire cluster.
*
* @return the GemFire {@link Pool} used by this {@link ClientCache} to obtain connections
* to the GemFire cluster.
* @return the Pivotal GemFire {@link Pool} used by this {@link ClientCache} to obtain connections
* to the Pivotal GemFire cluster.
*/
public Pool getPool() {
return this.pool;
}
/**
* Sets the name of the {@link Pool} used by this cache client to obtain connections to the GemFire cluster.
* Sets the name of the {@link Pool} used by this cache client to obtain connections to the Pivotal GemFire cluster.
*
* @param poolName set the name of the GemFire {@link Pool} used by this GemFire {@link ClientCache}.
* @param poolName set the name of the Pivotal GemFire {@link Pool} used by this Pivotal GemFire {@link ClientCache}.
* @throws IllegalArgumentException if the {@link Pool} name is unspecified.
*/
public void setPoolName(String poolName) {
@@ -698,9 +698,9 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Gets the name of the GemFire {@link Pool} used by this GemFire cache client.
* Gets the name of the Pivotal GemFire {@link Pool} used by this Pivotal GemFire cache client.
*
* @return the name of the GemFire {@link Pool} used by this GemFire cache client.
* @return the name of the Pivotal GemFire {@link Pool} used by this Pivotal GemFire cache client.
*/
public String getPoolName() {
return poolName;
@@ -758,10 +758,10 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
}
/**
* Determines whether this GemFire cache client is ready for events. If 'readyForEvents' was explicitly set,
* Determines whether this Pivotal GemFire cache client is ready for events. If 'readyForEvents' was explicitly set,
* then it takes precedence over all other considerations (e.g. durability).
*
* @return a boolean value indicating whether this GemFire cache client is ready for events.
* @return a boolean value indicating whether this Pivotal GemFire cache client is ready for events.
* @see org.springframework.data.gemfire.GemfireUtils#isDurable(ClientCache)
* @see #getReadyForEvents()
*/

View File

@@ -530,7 +530,7 @@ public class ClientRegionFactoryBean<K, V> extends RegionLookupFactoryBean<K, V>
/**
* Sets the CacheLoader used to load data local to the client's Region on cache misses.
*
* @param cacheLoader a GemFire CacheLoader used to load data into the client Region.
* @param cacheLoader a Pivotal GemFire CacheLoader used to load data into the client Region.
* @see org.apache.geode.cache.CacheLoader
*/
public void setCacheLoader(CacheLoader<K, V> cacheLoader) {
@@ -540,7 +540,7 @@ public class ClientRegionFactoryBean<K, V> extends RegionLookupFactoryBean<K, V>
/**
* Sets the CacheWriter used to perform a synchronous write-behind when data is put into the client's Region.
*
* @param cacheWriter the GemFire CacheWriter used to perform synchronous write-behinds on put ops.
* @param cacheWriter the Pivotal GemFire CacheWriter used to perform synchronous write-behinds on put ops.
* @see org.apache.geode.cache.CacheWriter
*/
public void setCacheWriter(CacheWriter<K, V> cacheWriter) {

View File

@@ -21,7 +21,7 @@ import org.springframework.core.convert.converter.Converter;
/**
* The ClientRegionShortcutConverter class is a Spring Converter implementation converting String value Client Region
* Shortcut representations into actual GemFire ClientRegionShortcut enumerated values.
* Shortcut representations into actual Pivotal GemFire ClientRegionShortcut enumerated values.
*
* @author John Blum
* @see org.springframework.core.convert.converter.Converter

View File

@@ -21,10 +21,12 @@ import org.apache.geode.cache.client.ClientRegionShortcut;
import org.springframework.util.ObjectUtils;
/**
* The {@link ClientRegionShortcutWrapper} enum is a Java enumerated type that wraps GemFire's {@link ClientRegionShortcut ClientRegionShortcuts}
* with Spring Data GemFire {@link ClientRegionShortcutWrapper} enumerated values.
* The {@link ClientRegionShortcutWrapper} enum is a Java enumerated type that wraps Pivotal GemFire's
* {@link ClientRegionShortcut ClientRegionShortcuts} with SDG {@link ClientRegionShortcutWrapper}
* enumerated values.
*
* @author John Blum
* @see org.apache.geode.cache.DataPolicy
* @see org.apache.geode.cache.client.ClientRegionShortcut
* @since 1.4.0
*/

View File

@@ -35,7 +35,7 @@ import org.springframework.util.ObjectUtils;
/**
* A Spring {@link BeanFactoryPostProcessor} used to register a Client Region Proxy bean for each Region
* accessible to a GemFire DataSource. If the Region is already defined, the bean definition will not be overridden.
* accessible to a Pivotal GemFire DataSource. If the Region is already defined, the bean definition will not be overridden.
*
* @author David Turanski
* @author John Blum
@@ -58,10 +58,10 @@ public class GemfireDataSourcePostProcessor implements BeanFactoryPostProcessor
/**
* Constructs an instance of the GemfireDataSourcePostProcessor BeanFactoryPostProcessor class initialized
* with the specified GemFire ClientCache instance for creating client PROXY Regions for all data Regions
* configured in the GemFire cluster.
* with the specified Pivotal GemFire ClientCache instance for creating client PROXY Regions for all data Regions
* configured in the Pivotal GemFire cluster.
*
* @param clientCache the GemFire ClientCache instance.
* @param clientCache the Pivotal GemFire ClientCache instance.
* @see org.apache.geode.cache.client.ClientCache
*/
public GemfireDataSourcePostProcessor(final ClientCache clientCache) {

View File

@@ -21,7 +21,7 @@ import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterS
/**
* The InterestResultPolicyConverter class is a Spring Converter and JavaBeans PropertyEditor capable of converting
* a String into a GemFire InterestResultPolicyConverter.
* a String into a Pivotal GemFire InterestResultPolicyConverter.
*
* @author John Blum
* @see org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport
@@ -31,11 +31,11 @@ import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterS
public class InterestResultPolicyConverter extends AbstractPropertyEditorConverterSupport<InterestResultPolicy> {
/**
* Converts the given String into an instance of GemFire InterestResultPolicy.
* Converts the given String into an instance of Pivotal GemFire InterestResultPolicy.
*
* @param source the String to convert into an InterestResultPolicy value.
* @return a GemFire InterestResultPolicy value for the given String.
* @throws java.lang.IllegalArgumentException if the String is not a valid GemFire InterestResultPolicy.
* @return a Pivotal GemFire InterestResultPolicy value for the given String.
* @throws java.lang.IllegalArgumentException if the String is not a valid Pivotal GemFire InterestResultPolicy.
* @see org.springframework.data.gemfire.client.InterestResultPolicyType#getInterestResultPolicy(InterestResultPolicyType)
* @see org.springframework.data.gemfire.client.InterestResultPolicyType#valueOfIgnoreCase(String)
* @see #assertConverted(String, Object, Class)

View File

@@ -28,9 +28,9 @@ import org.apache.geode.cache.query.QueryService;
* that conveniently enables implementing classes to extend this adapter to adapt their interfaces and serve
* as a {@link Pool}.
*
* For instance, one possible implementation is Spring Data GemFire's {@link PoolFactoryBean}, which can act as
* a {@link Pool} in a context where only the {@link Pool}'s "configuration" and meta-data are required,
* but not actual connections or operating state information (e.g. pendingEventCount).
* For instance, one possible implementation is SDG's {@link PoolFactoryBean}, which can act as a {@link Pool}
* in a context where only the {@link Pool}'s "configuration" and meta-data are required, but no actual connections
* or operating state information (e.g. pendingEventCount) is needed.
*
* @author John Blum
* @see org.springframework.data.gemfire.client.PoolFactoryBean
@@ -42,143 +42,114 @@ public abstract class PoolAdapter implements Pool {
public static final String NOT_IMPLEMENTED = "Not Implemented";
/* (non-Javadoc) */
public boolean isDestroyed() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getFreeConnectionTimeout() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public long getIdleTimeout() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getLoadConditioningInterval() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public List<InetSocketAddress> getLocators() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getMaxConnections() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getMinConnections() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public boolean getMultiuserAuthentication() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public String getName() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
@Override
public List<InetSocketAddress> getOnlineLocators() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getPendingEventCount() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public long getPingInterval() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public boolean getPRSingleHopEnabled() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public QueryService getQueryService() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getReadTimeout() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getRetryAttempts() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public String getServerGroup() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public List<InetSocketAddress> getServers() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getSocketBufferSize() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getStatisticInterval() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getSubscriptionAckInterval() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public boolean getSubscriptionEnabled() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getSubscriptionMessageTrackingTimeout() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public int getSubscriptionRedundancy() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public boolean getThreadLocalConnections() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public void destroy() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public void destroy(final boolean keepAlive) {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}
/* (non-Javadoc) */
public void releaseThreadLocalConnection() {
throw new UnsupportedOperationException(NOT_IMPLEMENTED);
}

View File

@@ -78,7 +78,7 @@ public class PoolFactoryBean extends AbstractFactoryBeanSupport<Pool> implements
// indicates whether the Pool has been created internally (by this FactoryBean) or not
volatile boolean springBasedPool = true;
// GemFire Pool Configuration Settings
// Pivotal GemFire Pool Configuration Settings
private boolean keepAlive = false;
private boolean multiUserAuthentication = PoolFactory.DEFAULT_MULTIUSER_AUTHENTICATION;
private boolean prSingleHopEnabled = PoolFactory.DEFAULT_PR_SINGLE_HOP_ENABLED;

View File

@@ -26,8 +26,8 @@ import org.apache.geode.cache.execute.Function;
import org.apache.geode.cache.execute.FunctionContext;
/**
* ListRegionsOnServerFunction is a GemFire Function class that returns a List of names for all Regions
* defined in the GemFire cluster.
* ListRegionsOnServerFunction is a Pivotal GemFire Function class that returns a List of names for all Regions
* defined in the Pivotal GemFire cluster.
*
* @author David Turanski
* @author John Blum

View File

@@ -1,6 +1,6 @@
/**
*
* Classes providing support for GemFire client configuration.
* Classes providing support for Pivotal GemFire client configuration.
*
*/
package org.springframework.data.gemfire.client;
package org.springframework.data.gemfire.client;

View File

@@ -25,8 +25,8 @@ import org.apache.geode.cache.client.Pool;
import org.apache.geode.cache.query.QueryService;
/**
* DelegatingPoolAdapter is an abstract implementation of GemFire's {@link Pool} interface and extension of
* {@link FactoryDefaultsPoolAdapter} that delegates operations to the provided {@link Pool} instance.
* {@link DelegatingPoolAdapter} is an abstract implementation of Pivotal GemFire's {@link Pool} interface
* and extension of {@link FactoryDefaultsPoolAdapter} that delegates operations to the provided {@link Pool} instance.
*
* However, this implementation guards against a potentially <code>null</code> {@link Pool} reference by returning
* default factory settings for the {@link Pool}'s configuration properties along with default behavior for operations
@@ -42,7 +42,6 @@ public abstract class DelegatingPoolAdapter extends FactoryDefaultsPoolAdapter {
private final Pool delegate;
/* (non-Javadoc) */
public static DelegatingPoolAdapter from(Pool delegate) {
return new DelegatingPoolAdapter(delegate) { };
}
@@ -57,184 +56,155 @@ public abstract class DelegatingPoolAdapter extends FactoryDefaultsPoolAdapter {
this.delegate = delegate;
}
/* (non-Javadoc) */
protected Pool getDelegate() {
return delegate;
}
/* (non-Javadoc) */
@Override
public boolean isDestroyed() {
return Optional.ofNullable(getDelegate()).map(Pool::isDestroyed).orElseGet(super::isDestroyed);
}
/* (non-Javadoc) */
@Override
public int getFreeConnectionTimeout() {
return Optional.ofNullable(getDelegate()).map(Pool::getFreeConnectionTimeout)
.orElseGet(super::getFreeConnectionTimeout);
}
/* (non-Javadoc) */
@Override
public long getIdleTimeout() {
return Optional.ofNullable(getDelegate()).map(Pool::getIdleTimeout).orElseGet(super::getIdleTimeout);
}
/* (non-Javadoc) */
@Override
public int getLoadConditioningInterval() {
return Optional.ofNullable(getDelegate()).map(Pool::getLoadConditioningInterval)
.orElseGet(super::getLoadConditioningInterval);
}
/* (non-Javadoc) */
@Override
public List<InetSocketAddress> getLocators() {
return Optional.ofNullable(getDelegate()).map(Pool::getLocators).orElseGet(super::getLocators);
}
/* (non-Javadoc) */
@Override
public int getMaxConnections() {
return Optional.ofNullable(getDelegate()).map(Pool::getMaxConnections).orElseGet(super::getMaxConnections);
}
/* (non-Javadoc) */
@Override
public int getMinConnections() {
return Optional.ofNullable(getDelegate()).map(Pool::getMinConnections).orElseGet(super::getMinConnections);
}
/* (non-Javadoc) */
@Override
public boolean getMultiuserAuthentication() {
return Optional.ofNullable(getDelegate()).map(Pool::getMultiuserAuthentication)
.orElseGet(super::getMultiuserAuthentication);
}
/* (non-Javadoc) */
@Override
public String getName() {
return Optional.ofNullable(getDelegate()).map(Pool::getName).orElseGet(super::getName);
}
/* (non-Javadoc) */
@Override
public List<InetSocketAddress> getOnlineLocators() {
return Optional.ofNullable(getDelegate()).map(Pool::getOnlineLocators).orElseGet(super::getOnlineLocators);
}
/* (non-Javadoc) */
@Override
public int getPendingEventCount() {
return Optional.ofNullable(getDelegate()).map(Pool::getPendingEventCount).orElse(0);
}
/* (non-Javadoc) */
@Override
public long getPingInterval() {
return Optional.ofNullable(getDelegate()).map(Pool::getPingInterval).orElseGet(super::getPingInterval);
}
/* (non-Javadoc) */
@Override
public boolean getPRSingleHopEnabled() {
return Optional.ofNullable(getDelegate()).map(Pool::getPRSingleHopEnabled)
.orElseGet(super::getPRSingleHopEnabled);
}
/* (non-Javadoc) */
@Override
public QueryService getQueryService() {
return Optional.ofNullable(getDelegate()).map(Pool::getQueryService).orElseGet(super::getQueryService);
}
/* (non-Javadoc) */
@Override
public int getReadTimeout() {
return Optional.ofNullable(getDelegate()).map(Pool::getReadTimeout).orElseGet(super::getReadTimeout);
}
/* (non-Javadoc) */
@Override
public int getRetryAttempts() {
return Optional.ofNullable(getDelegate()).map(Pool::getRetryAttempts).orElseGet(super::getRetryAttempts);
}
/* (non-Javadoc) */
@Override
public String getServerGroup() {
return Optional.ofNullable(getDelegate()).map(Pool::getServerGroup).orElseGet(super::getServerGroup);
}
/* (non-Javadoc) */
@Override
public List<InetSocketAddress> getServers() {
return Optional.ofNullable(getDelegate()).map(Pool::getServers).orElseGet(super::getServers);
}
/* (non-Javadoc) */
@Override
public int getSocketBufferSize() {
return Optional.ofNullable(getDelegate()).map(Pool::getSocketBufferSize).orElseGet(super::getSocketBufferSize);
}
/* (non-Javadoc) */
@Override
public int getStatisticInterval() {
return Optional.ofNullable(getDelegate()).map(Pool::getStatisticInterval)
.orElseGet(super::getStatisticInterval);
}
/* (non-Javadoc) */
@Override
public int getSubscriptionAckInterval() {
return Optional.ofNullable(getDelegate()).map(Pool::getSubscriptionAckInterval)
.orElseGet(super::getSubscriptionAckInterval);
}
/* (non-Javadoc) */
@Override
public boolean getSubscriptionEnabled() {
return Optional.ofNullable(getDelegate()).map(Pool::getSubscriptionEnabled)
.orElseGet(super::getSubscriptionEnabled);
}
/* (non-Javadoc) */
@Override
public int getSubscriptionMessageTrackingTimeout() {
return Optional.ofNullable(getDelegate()).map(Pool::getSubscriptionMessageTrackingTimeout)
.orElseGet(super::getSubscriptionMessageTrackingTimeout);
}
/* (non-Javadoc) */
@Override
public int getSubscriptionRedundancy() {
return Optional.ofNullable(getDelegate()).map(Pool::getSubscriptionRedundancy)
.orElseGet(super::getSubscriptionRedundancy);
}
/* (non-Javadoc) */
@Override
public boolean getThreadLocalConnections() {
return Optional.ofNullable(getDelegate()).map(Pool::getThreadLocalConnections)
.orElseGet(super::getThreadLocalConnections);
}
/* (non-Javadoc) */
@Override
public void destroy() {
Optional.ofNullable(getDelegate()).ifPresent(Pool::destroy);
}
/* (non-Javadoc) */
@Override
public void destroy(boolean keepAlive) {
Optional.ofNullable(getDelegate()).ifPresent(delegate -> delegate.destroy(keepAlive));
}
/* (non-Javadoc) */
@Override
public void releaseThreadLocalConnection() {
Optional.ofNullable(getDelegate()).ifPresent(Pool::releaseThreadLocalConnection);

View File

@@ -38,9 +38,9 @@ public class AbstractGemfireAdminOperations implements GemfireAdminOperations {
protected static final String NOT_IMPLEMENTED = "Not Implemented";
/**
* Returns a {@link Iterable collection} of {@link Region} names defined on the GemFire Servers in the cluster.
* Returns a {@link Iterable collection} of {@link Region} names defined on the Pivotal GemFire Servers in the cluster.
*
* @return an {@link Iterable} of {@link Region} names defined on the GemFire Servers in the cluster.
* @return an {@link Iterable} of {@link Region} names defined on the Pivotal GemFire Servers in the cluster.
* @see org.apache.geode.cache.Region#getName()
* @see java.lang.Iterable
*/

View File

@@ -46,9 +46,9 @@ import org.springframework.data.gemfire.config.schema.definitions.RegionDefiniti
public interface GemfireAdminOperations {
/**
* Returns a {@link Iterable collection} of {@link Region} names defined on the GemFire Servers in the cluster.
* Returns a {@link Iterable collection} of {@link Region} names defined on the Pivotal GemFire Servers in the cluster.
*
* @return an {@link Iterable} of {@link Region} names defined on the GemFire Servers in the cluster.
* @return an {@link Iterable} of {@link Region} names defined on the Pivotal GemFire Servers in the cluster.
* @see org.apache.geode.cache.Region#getName()
* @see java.lang.Iterable
*/

View File

@@ -47,7 +47,7 @@ import org.springframework.util.Assert;
* in the cluster.
*
* Note: any schema changing functionality (e.g. {@link #createRegion(RegionDefinition)}) does not get recorded by
* the GemFire/Geode Cluster Configuration Service using this strategy.
* the Pivotal GemFire/Apache Geode Cluster Configuration Service using this strategy.
*
* @author John Blum
* @see org.apache.geode.cache.client.ClientCache
@@ -91,7 +91,7 @@ public class FunctionGemfireAdminTemplate extends AbstractGemfireAdminOperations
* / Apache Geode cluster.
*
* @return an {@link Iterable} of servers-side {@link Region} names for all {@link Region Regions} defined
* across all servers in the remote GemFire/Geode cluster.
* across all servers in the remote Pivotal GemFire/Apache Geode cluster.
* @see java.lang.Iterable
*/
@Override

View File

@@ -67,7 +67,7 @@ public class RestHttpGemfireAdminTemplate extends FunctionGemfireAdminTemplate {
/**
* Constructs an instance of the {@link RestHttpGemfireAdminTemplate} initialized with
* the given {@link ClientCache} and configured with the default host and port when accessing
* the GemFire or Geode Management REST API interface.
* the Pivotal GemFire or Geode Management REST API interface.
*
* @param clientCache reference to the {@link ClientCache}
* @throws IllegalArgumentException if the {@link ClientCache} reference is {@literal null}.
@@ -80,11 +80,11 @@ public class RestHttpGemfireAdminTemplate extends FunctionGemfireAdminTemplate {
/**
* Constructs an instance of the {@link RestHttpGemfireAdminTemplate} initialized with
* the given {@link ClientCache} and configured with the specified host and port when accessing
* the GemFire or Geode Management REST API interface.
* the Pivotal GemFire or Geode Management REST API interface.
*
* @param clientCache reference to the {@link ClientCache}
* @param host {@link String} containing the hostname of the GemFire/Geode Manager.
* @param port integer value specifying the port on which the GemFire/Geode Manager HTTP Service is listening
* @param host {@link String} containing the hostname of the Pivotal GemFire/Apache Geode Manager.
* @param port integer value specifying the port on which the Pivotal GemFire/Apache Geode Manager HTTP Service is listening
* for HTTP clients.
* @throws IllegalArgumentException if the {@link ClientCache} reference is {@literal null}.
* @see org.apache.geode.cache.client.ClientCache
@@ -111,7 +111,7 @@ public class RestHttpGemfireAdminTemplate extends FunctionGemfireAdminTemplate {
/**
* Resolves the Pivotal GemFire or Apache Geode Management REST API URL given the host and port
* of the GemFire/Geode Manager's embedded HTTP service.
* of the Pivotal GemFire/Apache Geode Manager's embedded HTTP service.
*
* @param host {@link String} containing the hostname of the Manager running the embedded HTTP service
* and Management REST API.
@@ -123,9 +123,9 @@ public class RestHttpGemfireAdminTemplate extends FunctionGemfireAdminTemplate {
}
/**
* Returns a reference to the resolved GemFire/Geode Management REST API URL.
* Returns a reference to the resolved Pivotal GemFire/Apache Geode Management REST API URL.
*
* @return a {@link String} containing the resolved GemFire/Geode Management REST API URL.
* @return a {@link String} containing the resolved Pivotal GemFire/Apache Geode Management REST API URL.
*/
protected String getManagementRestApiUrl() {
return this.managementRestApiUrl;

View File

@@ -167,7 +167,7 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
*
* @return a {@link Properties} object containing Pivotal GemFire/Apache Geode properties used to configure
* the Pivotal GemFire/Apache Geode cache instance.
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/reference/topics/gemfire_properties.html">GemFire Properties</a>
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/reference/topics/gemfire_properties.html">Pivotal GemFire Properties</a>
* @see java.util.Properties
* @see #locators()
* @see #logLevel()
@@ -202,11 +202,11 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
}
/**
* Configures Spring container infrastructure components and beans used by Spring Data GemFire
* to enable Pivotal GemFire or Apache Geode to function properly inside a Spring context.
* Configures Spring container infrastructure components and beans used by SDG to enable Pivotal GemFire
* or Apache Geode to function properly inside a Spring context.
*
* @param importMetadata {@link AnnotationMetadata} containing annotation meta-data
* for the Spring Data GemFire cache application class.
* for the SDG cache application class.
* @see org.springframework.core.type.AnnotationMetadata
*/
protected void configureInfrastructure(AnnotationMetadata importMetadata) {
@@ -308,7 +308,7 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
* @param importMetadata {@link AnnotationMetadata} containing PDX meta-data used to configure the cache
* with PDX de/serialization capabilities.
* @see org.springframework.core.type.AnnotationMetadata
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/latest/developing/data_serialization/gemfire_pdx_serialization.html">GemFire PDX Serialization</a>
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/latest/developing/data_serialization/gemfire_pdx_serialization.html">Pivotal GemFire PDX Serialization</a>
*/
protected void configurePdx(AnnotationMetadata importMetadata) {
@@ -491,13 +491,13 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
// REVIEW JAVADOC FROM HERE
/**
* Determines whether this is a GemFire {@link org.apache.geode.cache.server.CacheServer} application,
* Determines whether this is a Pivotal GemFire {@link org.apache.geode.cache.server.CacheServer} application,
* which is indicated by the presence of the {@link CacheServerApplication} annotation on a Spring application
* {@link org.springframework.context.annotation.Configuration @Configuration} class.
*
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
* from the annotations used to configure the Spring application.
* @return a boolean value indicating whether this is a GemFire cache server application.
* @return a boolean value indicating whether this is a Pivotal GemFire cache server application.
* @see org.springframework.data.gemfire.config.annotation.CacheServerApplication
* @see #isTypedCacheApplication(Class, AnnotationMetadata)
*/
@@ -506,13 +506,13 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
}
/**
* Determines whether this is a GemFire {@link org.apache.geode.cache.client.ClientCache} application,
* Determines whether this is a Pivotal GemFire {@link org.apache.geode.cache.client.ClientCache} application,
* which is indicated by the presence of the {@link ClientCacheApplication} annotation on a Spring application
* {@link org.springframework.context.annotation.Configuration @Configuration} class.
*
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
* from the annotations used to configure the Spring application.
* @return a boolean value indicating whether this is a GemFire cache client application.
* @return a boolean value indicating whether this is a Pivotal GemFire cache client application.
* @see org.springframework.data.gemfire.config.annotation.ClientCacheApplication
* @see #isTypedCacheApplication(Class, AnnotationMetadata)
*/
@@ -521,13 +521,13 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
}
/**
* Determines whether this is a GemFire peer {@link org.apache.geode.cache.Cache} application,
* Determines whether this is a Pivotal GemFire peer {@link org.apache.geode.cache.Cache} application,
* which is indicated by the presence of the {@link PeerCacheApplication} annotation on a Spring application
* {@link org.springframework.context.annotation.Configuration @Configuration} class.
*
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
* from the annotations used to configure the Spring application.
* @return a boolean value indicating whether this is a GemFire peer cache application.
* @return a boolean value indicating whether this is a Pivotal GemFire peer cache application.
* @see org.springframework.data.gemfire.config.annotation.PeerCacheApplication
* @see #isTypedCacheApplication(Class, AnnotationMetadata)
*/
@@ -536,7 +536,7 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
}
/**
* Determines whether this Spring application is annotated with the given GemFire cache type annotation.
* Determines whether this Spring application is annotated with the given Pivotal GemFire cache type annotation.
*
* @param annotationType {@link Annotation} cache type.
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
@@ -555,14 +555,14 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
}
/**
* Determines whether this is a GemFire {@link org.apache.geode.cache.server.CacheServer} or
* Determines whether this is a Pivotal GemFire {@link org.apache.geode.cache.server.CacheServer} or
* {@link org.apache.geode.cache.Cache peer cache} application, which is indicated by the presence
* of either the {@link CacheServerApplication} annotation or the {@link PeerCacheApplication} annotation
* on a Spring application {@link org.springframework.context.annotation.Configuration @Configuration} class.
*
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
* from the annotations used to configure the Spring application.
* @return a boolean value indicating whether this is a GemFire cache server or peer cache application.
* @return a boolean value indicating whether this is a Pivotal GemFire cache server or peer cache application.
* @see org.springframework.core.type.AnnotationMetadata
* @see org.springframework.data.gemfire.config.annotation.CacheServerApplication
* @see org.springframework.data.gemfire.config.annotation.PeerCacheApplication
@@ -579,7 +579,7 @@ public abstract class AbstractCacheConfiguration extends AbstractAnnotationConfi
*
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
* from the class type-level annotations used to configure the Spring application.
* @return a boolean value indicating whether this is a GemFire cache server, client cache or peer cache
* @return a boolean value indicating whether this is a Pivotal GemFire cache server, client cache or peer cache
* Spring application.
* @see #isCacheServerApplication(AnnotationMetadata)
* @see #isClientCacheApplication(AnnotationMetadata)

View File

@@ -26,7 +26,7 @@ import org.springframework.core.type.AnnotationMetadata;
/**
* The {@link AddCacheServersConfiguration} class registers {@link org.springframework.data.gemfire.server.CacheServerFactoryBean}
* bean definitions for all {@link EnableCacheServer} annotation configuration meta-data defined in
* the {@link EnableCacheServers} annotation on a GemFire peer cache application class.
* the {@link EnableCacheServers} annotation on a Pivotal GemFire peer cache application class.
*
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.AddCacheServerConfiguration

View File

@@ -225,9 +225,9 @@ public class AddPoolConfiguration extends AbstractAnnotationConfigSupport
}
/**
* Uses the list of GemFire Locator and Server connection endpoint definitions and meta-data to configure
* the GemFire client {@link org.apache.geode.cache.client.Pool} used to communicate with the servers
* in the GemFire cluster.
* Uses the list of Pivotal GemFire Locator and Server connection endpoint definitions and meta-data to configure
* the Pivotal GemFire client {@link org.apache.geode.cache.client.Pool} used to communicate with the servers
* in the Pivotal GemFire cluster.
*
* @param enablePoolAttributes {@link EnablePool} annotation containing
* {@link org.apache.geode.cache.client.Pool} Locator/Server connection endpoint meta-data.

View File

@@ -26,7 +26,7 @@ import org.springframework.core.type.AnnotationMetadata;
/**
* The {@link AddPoolsConfiguration} class registers {@link org.springframework.data.gemfire.client.PoolFactoryBean}
* bean definitions for all {@link EnablePool} annotation configuration meta-data defined in
* the {@link EnablePools} annotation on a GemFire client cache application class.
* the {@link EnablePools} annotation on a Pivotal GemFire client cache application class.
* @author John Blum
* @see org.apache.geode.cache.client.Pool

View File

@@ -143,9 +143,9 @@ public class ApacheShiroSecurityConfiguration extends AbstractAnnotationConfigSu
* declared in the Spring {@link org.springframework.context.ApplicationContext}.
*
* This {@link Bean} definition declares a dependency on the Apache Geode {@link GemFireCache} instance
* in order to ensure the Geode cache is created and initialized first. This ensures that any internal Geode
* security configuration logic is evaluated and processed before SDG attempts to configure Apache Shiro
* as Apache Geode's security provider.
* in order to ensure the Apache Geode cache is created and initialized first. This ensures that any internal
* Apache Geode security configuration logic is evaluated and processed before SDG attempts to configure
* Apache Shiro as Apache Geode's security provider.
*
* Additionally, this {@link Bean} definition will register the Apache Shiro
* {@link org.apache.geode.security.SecurityManager} with the Apache Shiro security framework

View File

@@ -33,7 +33,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link AutoConfiguredAuthenticationConfiguration} class is a Spring {@link Configuration @Configuration} class
* that auto-configures Pivotal GemFire / Apache Geode Authentication by providing a implementation
* of the {@link org.apache.geode.security.AuthInitialize} interface along with setting the necessary GemFire / Geode
* of the {@link org.apache.geode.security.AuthInitialize} interface along with setting the necessary Pivotal GemFire / Geode
* properties.
*
* @author John Blum

View File

@@ -45,12 +45,12 @@ import org.springframework.util.StringUtils;
/**
* The {@link AutoRegionLookupConfiguration} class is a Spring {@link ImportBeanDefinitionRegistrar} that enables
* the automatic lookup of GemFire Regions, which may have been defined else where, such as in {@literal cache.xml}
* or using GemFire's Cluster Configuration Service.
* the automatic lookup of Pivotal GemFire Regions, which may have been defined else where, such as in {@literal cache.xml}
* or using Pivotal GemFire's Cluster Configuration Service.
*
* This registrar works by registering the {@link AutoRegionLookupBeanPostProcessor} in the Spring application context,
* which is enabled when a Spring {@link org.springframework.context.annotation.Configuration @Configuration} annotated
* GemFire cache application class is annotated with {@link EnableAutoRegionLookup}.
* Pivotal GemFire cache application class is annotated with {@link EnableAutoRegionLookup}.
*
* @author John Blum
* @see org.springframework.beans.factory.BeanFactory
@@ -79,7 +79,6 @@ public class AutoRegionLookupConfiguration extends AbstractAnnotationConfigSuppo
private StandardEvaluationContext evaluationContext = new StandardEvaluationContext();
/* (non-Javadoc) */
@Override
protected Class getAnnotationType() {
return EnableAutoRegionLookup.class;
@@ -153,7 +152,6 @@ public class AutoRegionLookupConfiguration extends AbstractAnnotationConfigSuppo
return DEFAULT_ENABLED;
}
/* (non-Javadoc) */
private void registerAutoRegionLookupBeanPostProcessor(BeanDefinitionRegistry registry) {
if (AUTO_REGION_LOOKUP_BEAN_POST_PROCESSOR_REGISTERED.compareAndSet(false, true)) {

View File

@@ -25,8 +25,8 @@ import org.springframework.data.gemfire.support.GemfireBeanFactoryLocator;
/**
* The {@link BeanFactoryLocatorConfiguration} class extends the Spring application configuration by enabling
* Spring Data GemFire/Geode's {@link GemfireBeanFactoryLocator} in order to auto-wire and configure any
* GemFire/Geode Objects declared in GemFire/Geode config (e.g. XML or properties).
* SDG's {@link GemfireBeanFactoryLocator} in order to auto-wire and configure any Pivotal GemFire/Apache Geode objects
* declared in Pivotal GemFire/Apache Geode config (e.g. XML or properties).
*
* @author John Blum
* @see org.springframework.beans.factory.config.BeanPostProcessor
@@ -42,8 +42,8 @@ import org.springframework.data.gemfire.support.GemfireBeanFactoryLocator;
public class BeanFactoryLocatorConfiguration {
/**
* Declares and registers a Spring {@link BeanPostProcessor} and post processes a Spring Data GemFire/Geode
* {@link CacheFactoryBean} by setting the {@literal useBeanFactoryLocator} property to {@literal true}.
* Declares and registers a Spring {@link BeanPostProcessor} and post processes a SDG {@link CacheFactoryBean}
* by setting the {@literal useBeanFactoryLocator} property to {@literal true}.
*
* @return a Spring {@link BeanPostProcessor} used to post process the SDG {@link CacheFactoryBean}.
* @see org.springframework.beans.factory.config.BeanPostProcessor

View File

@@ -33,10 +33,10 @@ import org.springframework.context.annotation.Import;
import org.springframework.data.gemfire.server.SubscriptionEvictionPolicy;
/**
* The CacheServerApplication annotation enables an embedded GemFire
* {@link org.apache.geode.cache.server.CacheServer} instance in a Spring Data GemFire based application.
* The CacheServerApplication annotation enables an embedded Pivotal GemFire {@link CacheServer} instance
* in a SDG-based application.
*
* In addition, this also implies an embedded GemFire peer {@link org.apache.geode.cache.Cache} must exist
* In addition, this also implies an embedded Pivotal GemFire peer {@link org.apache.geode.cache.Cache} must exist
* and therefore will be configured, constructed and initialized as a Spring bean in the application context.
*
* @author John Blum
@@ -107,7 +107,7 @@ public @interface CacheServerApplication {
float criticalOffHeapPercentage() default 0.0f;
/**
* By default, a GemFire member (both locators and servers) will attempt to reconnect and reinitialize the cache
* By default, a Pivotal GemFire member (both locators and servers) will attempt to reconnect and reinitialize the cache
* after it has been forced out of the distributed system by a network partition event or has otherwise been
* shunned by other members. Use this property to enable the auto-reconnect behavior.
*
@@ -185,7 +185,7 @@ public @interface CacheServerApplication {
int lockTimeout() default 60;
/**
* Configures the log level used to output log messages at GemFire cache runtime.
* Configures the log level used to output log messages at Pivotal GemFire cache runtime.
*
* Defaults to {@literal config}.
*
@@ -252,7 +252,7 @@ public @interface CacheServerApplication {
int messageTimeToLive() default CacheServer.DEFAULT_MESSAGE_TIME_TO_LIVE;
/**
* Configures the name of this GemFire member in the cluster (distributed system).
* Configures the name of this Pivotal GemFire member in the cluster (distributed system).
*
* Defaults to {@literal SpringBasedCacheServerApplication}.
*
@@ -318,8 +318,8 @@ public @interface CacheServerApplication {
/**
* Determines whether the Spring {@link BeanFactory} locator should be enabled to lookup
* the Spring {@link BeanFactory} to auto-wire and configure/initialize GemFire components
* created in a non-Spring managed, GemFire context.
* the Spring {@link BeanFactory} to auto-wire and configure/initialize Pivotal GemFire components
* created in a non-Spring managed, Pivotal GemFire context.
*
* Defaults to {@literal false}.
*
@@ -328,7 +328,7 @@ public @interface CacheServerApplication {
boolean useBeanFactoryLocator() default false;
/**
* Configures whether this GemFire cache member node would pull it's configuration meta-data
* Configures whether this Pivotal GemFire cache member node would pull it's configuration meta-data
* from the cluster-based Cluster Configuration service.
*
* Defaults to {@literal false}.

View File

@@ -67,7 +67,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link CachingDefinedRegionsConfiguration} class is a Spring {@link Configuration @Configuration} class
* that applies configuration to a Spring (Data GemFire/Geode) application to create GemFire/Geode cache
* that applies configuration to a Spring (Data Pivotal GemFire/Apache Geode) application to create Pivotal GemFire/Apache Geode cache
* {@link Region Regions} based on the use of Spring's Cache Abstraction to enable caching for application
* service classes and methods.
*

View File

@@ -33,8 +33,8 @@ import org.springframework.data.gemfire.GemfireUtils;
import org.springframework.data.gemfire.support.GemfireBeanFactoryLocator;
/**
* The {@link ClientCacheApplication} annotation enables a Spring Data GemFire based application to become
* a GemFire cache client (i.e. {@link org.apache.geode.cache.client.ClientCache}).
* The {@link ClientCacheApplication} annotation enables a SDG based application to become a
* Pivotal GemFire cache client (i.e. {@link org.apache.geode.cache.client.ClientCache}).
*
* @author John Blum
* @see org.apache.geode.cache.client.PoolFactory
@@ -163,7 +163,7 @@ public @interface ClientCacheApplication {
int loadConditioningInterval() default PoolFactory.DEFAULT_LOAD_CONDITIONING_INTERVAL;
/**
* Configures the GemFire {@link org.apache.geode.distributed.Locator Locators} to which
* Configures the Pivotal GemFire {@link org.apache.geode.distributed.Locator Locators} to which
* this cache client will connect.
*
* Use either the {@literal spring.data.gemfire.pool.default.locators} property
@@ -172,7 +172,7 @@ public @interface ClientCacheApplication {
Locator[] locators() default {};
/**
* Configures the log level used to output log messages at GemFire cache runtime.
* Configures the log level used to output log messages at Pivotal GemFire cache runtime.
*
* Defaults to {@literal config}.
*
@@ -212,7 +212,7 @@ public @interface ClientCacheApplication {
boolean multiUserAuthentication() default PoolFactory.DEFAULT_MULTIUSER_AUTHENTICATION;
/**
* Configures the name of this GemFire member in the cluster (distributed system).
* Configures the name of this Pivotal GemFire member in the cluster (distributed system).
*
* Defaults to {@literal SpringBasedCacheClientApplication}.
*
@@ -284,7 +284,7 @@ public @interface ClientCacheApplication {
String serverGroup() default PoolFactory.DEFAULT_SERVER_GROUP;
/**
* Configures the GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers} to which
* Configures the Pivotal GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers} to which
* this cache client will connect.
*
* Use either the {@literal spring.data.gemfire.pool.default.servers} property
@@ -369,8 +369,8 @@ public @interface ClientCacheApplication {
/**
* Determines whether the {@link GemfireBeanFactoryLocator} should be enabled to lookup
* the Spring {@link BeanFactory} to auto-wire and configure/initialize GemFire components
* created in a non-Spring managed, GemFire context.
* the Spring {@link BeanFactory} to auto-wire and configure/initialize Pivotal GemFire components
* created in a non-Spring managed, Pivotal GemFire context.
*
* Defaults to {@literal false}.
*

View File

@@ -190,14 +190,14 @@ public class ClientCacheConfiguration extends AbstractCacheConfiguration {
}
/**
* Configures Spring container infrastructure components and beans used by Spring Data GemFire
* to enable Pivotal GemFire or Apache Geode to function properly inside a Spring context.
* Configures Spring container infrastructure components and beans used by SDG to enable Pivotal GemFire
* or Apache Geode to function properly inside a Spring context.
*
* This overridden method configures and registers additional Spring components and bean applicable to
* {@link ClientCache ClientCaches}.
*
* @param importMetadata {@link AnnotationMetadata} containing annotation meta-data
* for the Spring Data GemFire cache application class.
* for the SDG cache application class.
* @see org.springframework.core.type.AnnotationMetadata
*/
@Override

View File

@@ -181,12 +181,12 @@ public class ClusterConfigurationConfiguration extends AbstractAnnotationConfigS
/**
* Constructs an instance of {@link GemfireAdminOperations} to perform administrative, schema functions
* on a GemFire cache cluster as well as a client cache from a cache client.
* on a Pivotal GemFire cache cluster as well as a client cache from a cache client.
*
* @param clientCache {@link ClientCache} instance used by the {@link GemfireAdminOperations} interface
* to access the GemFire system.
* to access the Pivotal GemFire system.
* @return an implementation of the {@link GemfireAdminOperations} interface to perform administrative functions
* on a GemFire system.
* on a Pivotal GemFire system.
* @see org.springframework.data.gemfire.config.admin.GemfireAdminOperations
* @see org.apache.geode.cache.client.ClientCache
*/
@@ -206,10 +206,10 @@ public class ClusterConfigurationConfiguration extends AbstractAnnotationConfigS
/**
* Constructs an instance of {@link SchemaObjectCollector} to inspect the application's context
* and find all the GemFire schema objects declared of a particular type or types.
* and find all the Pivotal GemFire schema objects declared of a particular type or types.
*
* @return a new instance of {@link SchemaObjectCollector} to inspect a GemFire system schema
* in search of specific GemFire schema objects (e.g. {@link Region} or {@link Index}).
* @return a new instance of {@link SchemaObjectCollector} to inspect a Pivotal GemFire system schema
* in search of specific Pivotal GemFire schema objects (e.g. {@link Region} or {@link Index}).
* @see org.springframework.data.gemfire.config.schema.SchemaObjectCollector
*/
private SchemaObjectCollector<?> newSchemaObjectCollector() {
@@ -221,7 +221,7 @@ public class ClusterConfigurationConfiguration extends AbstractAnnotationConfigS
}
/**
* Constructs an instance of {@link SchemaObjectDefiner} used to reverse engineer a GemFire schema object instance
* Constructs an instance of {@link SchemaObjectDefiner} used to reverse engineer a Pivotal GemFire schema object instance
* to build a definition.
*
* @return a new instance of {@link SchemaObjectDefiner}.

View File

@@ -21,7 +21,7 @@ import org.springframework.data.gemfire.listener.ContinuousQueryListenerContaine
/**
* The {@link ContinuousQueryListenerContainerConfigurer} interfaces defines a contract for implementations to customize
* the configuration of SDG's {@link ContinuousQueryListenerContainer} when enabling Continuous Query (CQ) functionality
* in Spring Boot, GemFire/Geode cache client applications.
* in Spring Boot, Pivotal GemFire/Apache Geode cache client applications.
*
* @author John Blum
* @see org.springframework.data.gemfire.listener.ContinuousQueryListenerContainer

View File

@@ -47,7 +47,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link DiskStoreConfiguration} class is a Spring {@link ImportBeanDefinitionRegistrar} used to register
* a GemFire/Geode {@link org.apache.geode.cache.DiskStore} bean definition.
* a Pivotal GemFire/Apache Geode {@link org.apache.geode.cache.DiskStore} bean definition.
*
* @author John Blum
* @see org.apache.geode.cache.DiskStore

View File

@@ -26,7 +26,7 @@ import org.springframework.core.type.AnnotationMetadata;
/**
* The {@link DiskStoresConfiguration} class is a Spring {@link org.springframework.context.annotation.ImportBeanDefinitionRegistrar}
* used to register multiple GemFire/Geode {@link org.apache.geode.cache.DiskStore} bean definitions.
* used to register multiple Pivotal GemFire/Apache Geode {@link org.apache.geode.cache.DiskStore} bean definitions.
*
* @author John Blum
* @see org.springframework.beans.factory.support.BeanDefinitionRegistry

View File

@@ -24,12 +24,14 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.apache.geode.cache.Region;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
/**
* The {@link EnableAutoRegionLookup} annotation configures a Spring {@link org.springframework.context.annotation.Configuration}
* annotated class with the ability to automatically look up and register GemFire {@link org.apache.geode.cache.Region Regions}
* which may have be defined in {@literal cache.xml} or by using GemFire's Cluster Configuration Service.
* The {@link EnableAutoRegionLookup} annotation configures a Spring {@link Configuration} annotated class
* with the ability to automatically look up and register Pivotal GemFire {@link Region Regions}
* which may have be defined in {@literal cache.xml} or by using Pivotal GemFire's Cluster Configuration Service.
*
* This annotation defines the {@code enabled} attribute to allow users to dynamically change the behavior
* of auto {@link org.apache.geode.cache.Region} lookup at application configuration time using either a SpEL

View File

@@ -29,8 +29,8 @@ import org.springframework.data.gemfire.support.GemfireBeanFactoryLocator;
/**
* The {@link EnableBeanFactoryLocator} annotation annotates a Spring {@link Configuration @Configuration} class
* enabling SDG's {@link GemfireBeanFactoryLocator} in order to auto-wire and configure GemFire/Geode Objects
* declared in GemFire/Geode config.
* enabling SDG's {@link GemfireBeanFactoryLocator} in order to auto-wire and configure Pivotal GemFire/Apache Geode Objects
* declared in Pivotal GemFire/Apache Geode config.
*
* @author John Blum
* @see java.lang.annotation.Documented

View File

@@ -31,10 +31,10 @@ import org.springframework.data.gemfire.server.SubscriptionEvictionPolicy;
/**
* The {@link EnableCacheServer} annotation configures a Spring {@link org.springframework.context.annotation.Configuration}
* annotated class with a GemFire {@link CacheServer} bean in the Spring application context.
* annotated class with a Pivotal GemFire {@link CacheServer} bean in the Spring application context.
*
* This annotation is used in conjunction with the {@link CacheServerApplication}, or {@link PeerCacheApplication}
* annotations to add an additional {@link CacheServer CacheServers} to a GemFire peer cache application
* annotations to add an additional {@link CacheServer CacheServers} to a Pivotal GemFire peer cache application
* configured with Spring (Data GemFire).
*
* To add more than 1 {@link CacheServer} to your application, this annotation can be nested in

View File

@@ -29,7 +29,7 @@ import org.springframework.context.annotation.Import;
/**
* The {@link EnableCacheServers} annotation enables 1 or more {@link CacheServer CacheServers}
* to be defined and used in a peer cache application configured with Spring (Data GemFire/Geode).
* to be defined and used in a peer cache application configured with Spring (Data Pivotal GemFire/Apache Geode).
*
* @author John Blum
* @see org.apache.geode.cache.server.CacheServer
@@ -47,7 +47,7 @@ import org.springframework.context.annotation.Import;
public @interface EnableCacheServers {
/**
* Enables the definition of multiple GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers}.
* Enables the definition of multiple Pivotal GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers}.
*/
EnableCacheServer[] servers() default {};

View File

@@ -35,7 +35,7 @@ import org.springframework.data.gemfire.mapping.annotation.ClientRegion;
/**
* The {@link EnableCachingDefinedRegions} annotation marks a Spring {@link Configuration @Configuration} application
* annotated class to enable the creation of GemFire/Geode {@link Region Regions} based on Spring's Cache Abstraction
* annotated class to enable the creation of Pivotal GemFire/Apache Geode {@link Region Regions} based on Spring's Cache Abstraction
* Annotations applied to application service methods and types.
*
* Additionally, this annotation enables Spring's Cache Abstraction with SDG's {@link EnableGemfireCaching} annotation,
@@ -78,7 +78,7 @@ public @interface EnableCachingDefinedRegions {
/**
* When this annotation is applied to a cache client application, the {@literal poolName} attribute refers to
* the default name of the GemFire/Geode {@link Pool} assigned to client {@link Region Region(s)}.
* the default name of the Pivotal GemFire/Apache Geode {@link Pool} assigned to client {@link Region Region(s)}.
*
* This value can be overridden by annotating entities with the {@link ClientRegion} annotation.
*

View File

@@ -30,9 +30,9 @@ import org.springframework.context.annotation.Import;
/**
* The {@link EnableClusterConfiguration} annotation enables Apache Geode / Pivotal GemFire schema-like definitions
* defined in a Spring [Boot], Geode/GemFire cache client application using Spring config to be pushed to
* a Geode/GemFire cluster, similar to how schema commands (e.g. `create region`) in Gfsh are processed by
* an Geode/GemFire Manager.
* defined in a Spring [Boot], Geode/Pivotal GemFire cache client application using Spring config to be pushed to
* a Geode/Pivotal GemFire cluster, similar to how schema commands (e.g. `create region`) in Gfsh are processed by
* an Geode/Pivotal GemFire Manager.
*
* @author John Blum
* @see java.lang.annotation.Documented
@@ -52,7 +52,7 @@ import org.springframework.context.annotation.Import;
public @interface EnableClusterConfiguration {
/**
* Configures the bind address used by the Spring, GemFire/Geode cache client application to locate
* Configures the bind address used by the Spring, Pivotal GemFire/Apache Geode cache client application to locate
* the Manager's HTTP Service and access the Management REST API. This configuration setting is only used
* when {@link #useHttp()} is set to {@literal true}.
*
@@ -64,7 +64,7 @@ public @interface EnableClusterConfiguration {
String host() default ClusterConfigurationConfiguration.DEFAULT_MANAGEMENT_HTTP_HOST;
/**
* Configures the port used by the Spring, GemFire/Geode cache client application to locate
* Configures the port used by the Spring, Pivotal GemFire/Apache Geode cache client application to locate
* the Manager's HTTP Service and access the Management REST API. This configuration setting is only used
* when {@link #useHttp()} is set to {@literal true}.
*
@@ -77,7 +77,7 @@ public @interface EnableClusterConfiguration {
/**
* Configuration setting used to specify the data management policy used when creating {@link Region Regions}
* on the servers in the Geode/GemFire cluster.
* on the servers in the Geode/Pivotal GemFire cluster.
*
* The data management policy is expressed with a {@link RegionShortcut}, but corresponds to the various
* different {@link DataPolicy DataPolicies} available.
@@ -90,7 +90,7 @@ public @interface EnableClusterConfiguration {
RegionShortcut serverRegionShortcut() default RegionShortcut.PARTITION;
/**
* Configures whether connectivity between the Spring, GemFire/Geode application should be established using HTTP.
* Configures whether connectivity between the Spring, Pivotal GemFire/Apache Geode application should be established using HTTP.
*
* Alternatively, you can configure this setting using the {@literal spring.data.gemfire.management.use-http}
* property in {@literal application.properties}.

View File

@@ -41,7 +41,7 @@ import org.springframework.core.annotation.AliasFor;
/**
* The {@link EnableDiskStore} annotation marks a Spring {@link Configuration @Configuration} annotated {@link Class}
* to configure a single GemFire/Geode {@link org.apache.geode.cache.DiskStore} bean in the Spring application context
* to configure a single Pivotal GemFire/Apache Geode {@link org.apache.geode.cache.DiskStore} bean in the Spring application context
* in which to persist or overflow data from 1 or more cache {@link org.apache.geode.cache.Region Regions}.
*
* @author John Blum

View File

@@ -28,8 +28,8 @@ import org.springframework.context.annotation.Import;
/**
* The {@link EnableDiskStores} annotation marks a Spring {@link org.springframework.context.annotation.Configuration @Configuration}
* annotated application class to configure 1 or more GemFire/Geode {@link org.apache.geode.cache.DiskStore} beans
* in the Spring context in which to persist or overflow data from 1 or more GemFire/Geode
* annotated application class to configure 1 or more Pivotal GemFire/Apache Geode {@link org.apache.geode.cache.DiskStore} beans
* in the Spring context in which to persist or overflow data from 1 or more Pivotal GemFire/Apache Geode
* {@link org.apache.geode.cache.Region Regions}
*
* @author John Blum
@@ -74,7 +74,7 @@ public @interface EnableDiskStores {
long maxOplogSize() default 1024L;
/**
* Defines 1 or more GemFire/Geode {@link org.apache.geode.cache.DiskStore DiskStores}.
* Defines 1 or more Pivotal GemFire/Apache Geode {@link org.apache.geode.cache.DiskStore DiskStores}.
*/
EnableDiskStore[] diskStores();

View File

@@ -38,7 +38,7 @@ import org.springframework.data.gemfire.mapping.annotation.ClientRegion;
/**
* The {@link EnableEntityDefinedRegions} annotation marks a Spring {@link Configuration @Configuration} application
* annotated class to enable the creation of GemFire/Geode {@link Region Regions} based on
* annotated class to enable the creation of Pivotal GemFire/Apache Geode {@link Region Regions} based on
* the application persistent entities.
*
* @author John Blum
@@ -144,7 +144,7 @@ public @interface EnableEntityDefinedRegions {
/**
* When this annotation is applied to a cache client application, the {@literal poolName} attribute refers to
* the default name of the GemFire/Geode {@link Pool} assigned to client {@link Region Region(s)}.
* the default name of the Pivotal GemFire/Apache Geode {@link Pool} assigned to client {@link Region Region(s)}.
*
* This value can be overridden by annotating entities with the {@link ClientRegion} annotation.
*

View File

@@ -46,7 +46,7 @@ import org.springframework.data.gemfire.expiration.TimeToLiveExpiration;
* @see org.springframework.data.gemfire.expiration.TimeToLiveExpiration
* @see org.apache.geode.cache.Region
* @see <a href="http://docs.spring.io/spring-data-gemfire/docs/current/reference/html/#bootstrap:region:expiration:annotation">Annotation-based Data Expiration</a>
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/latest/developing/expiration/chapter_overview.html">GemFire Expiration</a>
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/latest/developing/expiration/chapter_overview.html">Pivotal GemFire Expiration</a>
* @see <a href="http://geode.incubator.apache.org/docs/guide/developing/expiration/chapter_overview.html">Geode Expiration</a>
* @since 1.9.0
*/
@@ -126,10 +126,10 @@ public @interface EnableExpiration {
}
/**
* {@link ExpirationType} defines different types of GemFire/Geode Expiration policies such as
* {@link ExpirationType} defines different types of Pivotal GemFire/Apache Geode Expiration policies such as
* (Entry) Idle Timeout (TTI) and (Entry) Time to Live (TTL).
*
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/latest/developing/expiration/chapter_overview.html">GemFire Expiration</a>
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/latest/developing/expiration/chapter_overview.html">Pivotal GemFire Expiration</a>
* @see <a href="http://geode.incubator.apache.org/docs/guide/developing/expiration/chapter_overview.html">Geode Expiration</a>
*/
enum ExpirationType {

View File

@@ -27,7 +27,7 @@ import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.context.annotation.Import;
/**
* The {@link EnableGemFireAsLastResource} annotation is used to enable GemFire as a Last Resource in a Spring,
* The {@link EnableGemFireAsLastResource} annotation is used to enable Pivotal GemFire as a Last Resource in a Spring,
* CMT/JTA Transaction.
*
* @author John Blum

View File

@@ -28,11 +28,11 @@ import org.springframework.context.annotation.Import;
/**
* The {@link EnableGemFireProperties} annotation marks a Spring {@link org.springframework.context.annotation.Configuration @Configuration}
* annotated class to configure GemFire/Geode System properties at runtime during [Spring Boot] application startup.
* annotated class to configure Pivotal GemFire/Apache Geode System properties at runtime during [Spring Boot] application startup.
*
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.GemFirePropertiesConfiguration
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/reference/topics/gemfire_properties.html">GemFire System Properties</a>
* @see <a href="http://gemfire.docs.pivotal.io/docs-gemfire/reference/topics/gemfire_properties.html">Pivotal GemFire System Properties</a>
* @see <a href="http://geode.docs.pivotal.io/docs/reference/topics/gemfire_properties.html">Geode System Properties</a>
* @since 1.9.0
*/
@@ -105,7 +105,7 @@ public @interface EnableGemFireProperties {
/**
* Relevant only for multi-homed hosts - machines with multiple network interface cards (NICs).
* Specifies the adapter card the cache binds to for peer-to-peer (P2P) communication. Also specifies
* the default location for GemFire Servers to listen on, which is used unless overridden by
* the default location for Pivotal GemFire Servers to listen on, which is used unless overridden by
* the {@literal server-bind-address}. An empty string causes the member to listen on the default card
* for the machine. This is a machine-wide attribute used for system member and client/server communication.
* It has no effect on Locator location, unless the Locator is embedded in a member process.
@@ -149,9 +149,9 @@ public @interface EnableGemFireProperties {
* every application thread has its own sockets for distribution purposes. You can override
* this setting for individual threads inside your application. Where possible, it is better to
* set {@literal conserve-sockets} to {@literal true} and enable the use of specific extra sockets
* in the application code if needed. WAN deployments increase the messaging demands on a GemFire system.
* in the application code if needed. WAN deployments increase the messaging demands on a Pivotal GemFire system.
* To avoid hangs related to WAN messaging, always set {@literal conserve-sockets} to {@literal false}
* for GemFire members that participate in a WAN deployment.
* for Pivotal GemFire members that participate in a WAN deployment.
*
* Defaults to {@literal true}.
*/
@@ -169,7 +169,7 @@ public @interface EnableGemFireProperties {
* Working directory used when deploying JAR application files to distributed system members.
* This directory can be local and unique to the member or a shared resource.
*
* Defaults to current working directory of this GemFire JVM process.
* Defaults to current working directory of this Pivotal GemFire JVM process.
*/
String deployWorkingDirectory() default GemFirePropertiesConfiguration.DEFAULT_DEPLOY_WORKING_DIRECTORY;
@@ -208,7 +208,7 @@ public @interface EnableGemFireProperties {
/**
* Whether partitioned regions will put redundant copies of the same data in different members
* running on the same physical machine. By default, GemFire tries to put redundant copies on different machines,
* running on the same physical machine. By default, Pivotal GemFire tries to put redundant copies on different machines,
* but it will put them on the same machine if no other machines are available. Setting this property
* to {@literal true} prevents this and requires different machines for redundant copies.
*
@@ -263,7 +263,7 @@ public @interface EnableGemFireProperties {
long maxWaitTimeReconnect() default GemFirePropertiesConfiguration.DEFAULT_MAX_WAIT_TIME_RECONNECT;
/**
* GemFire uses the {@literal member-timeout} server configuration, specified in milliseconds, to detect
* Pivotal GemFire uses the {@literal member-timeout} server configuration, specified in milliseconds, to detect
* the abnormal termination of members. The configuration setting is used in two ways:
*
* 1) First, it is used during the UDP heartbeat detection process. When a member detects that
@@ -285,7 +285,7 @@ public @interface EnableGemFireProperties {
* The range of ports available for unicast UDP messaging and for TCP failure detection. This is specified
* as two integers separated by a hyphen. Different members can use different ranges.
*
* GemFire randomly chooses at least two unique integers from this range for the member, one for
* Pivotal GemFire randomly chooses at least two unique integers from this range for the member, one for
* UDP unicast messaging and the other for TCP failure detection messaging. If {@literal tcp-port}
* is configured to {@literal 0}, it will also randomly select a port from this range for TCP sockets
* used for peer-to-peer communication only.
@@ -295,7 +295,7 @@ public @interface EnableGemFireProperties {
*
* The system uniquely identifies the member using the combined host IP address and UDP port number.
*
* You may want to restrict the range of ports that GemFire uses so the product can run in an environment
* You may want to restrict the range of ports that Pivotal GemFire uses so the product can run in an environment
* where routers only allow traffic on certain ports.
*
* Defaults to {@literal 1024-65535}.
@@ -304,7 +304,7 @@ public @interface EnableGemFireProperties {
/**
* Defines this members redundancy zone. Used to separate members into different groups for satisfying
* Partitioned Region redundancy. If this property is set, GemFire will not put redundant copies of data
* Partitioned Region redundancy. If this property is set, Pivotal GemFire will not put redundant copies of data
* in members with the same redundancy zone setting.
*
* Defaults to unset.
@@ -375,7 +375,7 @@ public @interface EnableGemFireProperties {
* The TCP port to listen on for cache communications. If set to zero, the operating system selects
* an available port. Each process on a machine must have its own TCP port. Note that some operating systems
* restrict the range of ports usable by non-privileged users, and using restricted port numbers can cause
* runtime errors in GemFire startup.
* runtime errors in Pivotal GemFire startup.
*
* Valid values are in the range 0..65535.
*
@@ -384,7 +384,7 @@ public @interface EnableGemFireProperties {
int tcpPort() default GemFirePropertiesConfiguration.DEFAULT_TCP_PORT;
/**
* The number of tombstones that can accumulate before the GemFire member triggers garbage collection
* The number of tombstones that can accumulate before the Pivotal GemFire member triggers garbage collection
* for tombstones.
*
* Defaults to {@literal 100000} tombstones.

View File

@@ -57,9 +57,9 @@ import org.springframework.context.annotation.Import;
public @interface EnableHttpService {
/**
* If set, then the GemFire member binds the embedded HTTP service to the specified address.
* If set, then the Pivotal GemFire member binds the embedded HTTP service to the specified address.
* If this property is not set but the HTTP service is enabled using {@literal http-service-port},
* then GemFire binds the HTTP service to the members local address. Used by the GemFire Pulse Web application
* then Pivotal GemFire binds the HTTP service to the members local address. Used by the Pivotal GemFire Pulse Web application
* and the Developer REST API service.
*
* Defaults to unset.
@@ -69,8 +69,8 @@ public @interface EnableHttpService {
String bindAddress() default "";
/**
* If non-zero, then GemFire starts an embedded HTTP service that listens on this port. The HTTP service
* is used to host the GemFire Pulse Web application and the development REST API service. If you are hosting
* If non-zero, then Pivotal GemFire starts an embedded HTTP service that listens on this port. The HTTP service
* is used to host the Pivotal GemFire Pulse Web application and the development REST API service. If you are hosting
* the Pulse web app on your own Web server and are not using the Development REST API service, then disable
* this embedded HTTP service by setting this property to zero. Ignored if {@literal jmx-manager}
* and {@literal start-dev-rest-api} are both set to {@literal false}.
@@ -83,7 +83,7 @@ public @interface EnableHttpService {
/**
* Boolean indicating whether to require authentication for HTTP service connections. If this property is not set,
* then GemFire uses the value of {@literal cluster-ssl-require-authentication} to determine whether HTTP service
* then Pivotal GemFire uses the value of {@literal cluster-ssl-require-authentication} to determine whether HTTP service
* connections require authentication.
*
* To enable SSL communications for the HTTP service, use the {@link EnableSsl} annotation and set the

View File

@@ -30,7 +30,7 @@ import org.springframework.context.annotation.Configuration;
/**
* The {@link EnableIndexing} annotation marks a Spring {@link Configuration @Configuration} annotated application class
* to enable the creation of GemFire/Geode {@link Index Indexes} and {@link LuceneIndex LuceneIndexes} based on
* to enable the creation of Pivotal GemFire/Apache Geode {@link Index Indexes} and {@link LuceneIndex LuceneIndexes} based on
* application persistent entity field/property annotations, such as the {@link @Id}, {@link @Indexed}
* and {@link @LuceneIndex} annotations.
*
@@ -51,12 +51,12 @@ import org.springframework.context.annotation.Configuration;
public @interface EnableIndexing {
/**
* Determines whether all GemFire/Geode {@link Index Indexes} will be defined before created.
* Determines whether all Pivotal GemFire/Apache Geode {@link Index Indexes} will be defined before created.
* If set to {@literal true}, then all {@link Index Indexes} are defined first and the created
* in a single, bulk operation, thereby improving {@link Index} creation process efficiency.
*
* Only applies to OQL-based {@link Index Indexes}. {@link LuceneIndex LuceneIndexes} are managed differently
* by GemFire/Geode.
* by Pivotal GemFire/Apache Geode.
*
* Defaults to {@literal false}.
*/

View File

@@ -131,7 +131,7 @@ public @interface EnableManager {
/**
* The rate, in milliseconds, at which this member will push updates to any JMX Managers. Currently this value
* should be greater than or equal to the {@literal statistic-sample-rate}. Setting this value too high will
* cause stale values to be seen by Gfsh and GemFire Pulse.
* cause stale values to be seen by Gfsh and Pivotal GemFire Pulse.
*
* Defaults to {@literal 2000} milliseconds.
*

View File

@@ -31,10 +31,10 @@ import org.springframework.data.gemfire.GemfireUtils;
/**
* The {@link EnablePool} annotation configures a Spring {@link org.springframework.context.annotation.Configuration}
* annotated class with a "named" GemFire client {@link Pool} bean in the application context.
* annotated class with a "named" Pivotal GemFire client {@link Pool} bean in the application context.
*
* This annotation is used in conjunction with the {@link ClientCacheApplication} annotation to add an additional
* {@link Pool} to a GemFire cache client application configured with Spring (Data GemFire).
* {@link Pool} to a Pivotal GemFire cache client application configured with Spring (Data GemFire).
*
* To add more than 1 {@link Pool} to your application, this annotation can be nested in the {@link EnablePools}
* annotation.
@@ -90,7 +90,7 @@ public @interface EnablePool {
int loadConditioningInterval() default PoolFactory.DEFAULT_LOAD_CONDITIONING_INTERVAL;
/**
* Configures the GemFire {@link org.apache.geode.distributed.Locator Locators} to which
* Configures the Pivotal GemFire {@link org.apache.geode.distributed.Locator Locators} to which
* this cache client will connect.
*
* Use either the {@literal spring.data.gemfire.pool.<poolName>.locators} property
@@ -101,7 +101,7 @@ public @interface EnablePool {
/**
* A {@link String} containing a comma-delimited list of hosts and ports defining the connection endpoints
* of GemFire Locators in the cluster.
* of Pivotal GemFire Locators in the cluster.
*
* The {@link String} must be formatted as: 'host1[port], host2[port], ..., hostN[port]'.
*
@@ -210,7 +210,7 @@ public @interface EnablePool {
String serverGroup() default PoolFactory.DEFAULT_SERVER_GROUP;
/**
* Configures the GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers} to which
* Configures the Pivotal GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers} to which
* this cache client will connect.
*
* Use either the {@literal spring.data.gemfire.pool.<poolName>.servers} property
@@ -221,7 +221,7 @@ public @interface EnablePool {
/**
* A {@link String} containing a comma-delimited list of hosts and ports defining the connection endpoints
* of GemFire Servers in the cluster.
* of Pivotal GemFire Servers in the cluster.
*
* The {@link String} must be formatted as: 'host1[port], host2[port], ..., hostN[port]'.
*

View File

@@ -27,8 +27,8 @@ import java.lang.annotation.Target;
import org.springframework.context.annotation.Import;
/**
* The {@link EnablePools} annotation enables 1 or more GemFire {@link org.apache.geode.cache.client.Pool Pools}
* to be defined and used in a GemFire client cache application configured with Spring (Data GemFire).
* The {@link EnablePools} annotation enables 1 or more Pivotal GemFire {@link org.apache.geode.cache.client.Pool Pools}
* to be defined and used in a Pivotal GemFire client cache application configured with Spring (Data GemFire).
*
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.AddPoolsConfiguration
@@ -45,7 +45,7 @@ import org.springframework.context.annotation.Import;
public @interface EnablePools {
/**
* Enables the definition of multiple GemFire {@link org.apache.geode.cache.client.Pool Pools}.
* Enables the definition of multiple Pivotal GemFire {@link org.apache.geode.cache.client.Pool Pools}.
*/
EnablePool[] pools() default {};

View File

@@ -119,7 +119,7 @@ public @interface EnableSecurity {
String securityPostProcessorClassName() default "";
/**
* The {@literal security-username} used by a GemFire cache client application required to authenticate.
* The {@literal security-username} used by a Pivotal GemFire cache client application required to authenticate.
*
* Defaults to unset.
*
@@ -128,7 +128,7 @@ public @interface EnableSecurity {
String securityUsername() default "";
/**
* The {@literal security-password} used by a GemFire cache client application required to authenticate.
* The {@literal security-password} used by a Pivotal GemFire cache client application required to authenticate.
*
* Defaults to unset.
*
@@ -137,7 +137,7 @@ public @interface EnableSecurity {
String securityPassword() default "";
/**
* Sets the Geode System Property referring to the location of an Apache Shiro INI file used to configure
* Sets the Apache Geode System Property referring to the location of an Apache Shiro INI file used to configure
* the Apache Shiro Security Framework to secure Apache Geode.
*
* Default is unset.

View File

@@ -79,7 +79,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link EntityDefinedRegionsConfiguration} class is Spring {@link ImportBeanDefinitionRegistrar} used in
* the {@link EnableEntityDefinedRegions} annotation to dynamically create GemFire/Geode {@link Region Regions}
* the {@link EnableEntityDefinedRegions} annotation to dynamically create Pivotal GemFire/Apache Geode {@link Region Regions}
* based on the application persistent entity classes.
*
* @author John Blum

View File

@@ -195,16 +195,16 @@ public class EvictionConfiguration implements ApplicationContextAware, ImportAwa
}
/**
* {@link EvictionPolicyConfigurer} configures the Eviction policy of a GemFire {@link Region}.
* {@link EvictionPolicyConfigurer} configures the Eviction policy of a Pivotal GemFire {@link Region}.
*/
protected interface EvictionPolicyConfigurer {
/**
* Configure the Eviction policy on the given SDG {@link RegionFactoryBean} or {@link ClientRegionFactoryBean}
* used to create a GemFire {@link Region}.
* used to create a Pivotal GemFire {@link Region}.
*
* @param regionFactoryBean {@link RegionFactoryBean} or {@link ClientRegionFactoryBean} used to create
* a GemFire {@link Region}.
* a Pivotal GemFire {@link Region}.
* @return the given {@code regionFactoryBean}.
* @see org.springframework.data.gemfire.RegionFactoryBean
* @see org.springframework.data.gemfire.client.ClientRegionFactoryBean
@@ -352,7 +352,7 @@ public class EvictionConfiguration implements ApplicationContextAware, ImportAwa
* Resolves the Eviction policy threshold (a.k.a. maximum) based on the {@link EvictionPolicyType}.
*
* For instance {@link EvictionPolicyType#HEAP_PERCENTAGE} does not support maximum/threshold since
* the settings are determined by the GemFire/Geode cache critical heap percentage and eviction heap percentage
* the settings are determined by the Pivotal GemFire/Apache Geode cache critical heap percentage and eviction heap percentage
* System property settings.
*
* @param maximum integer value specifying the configured Eviction threshold.

View File

@@ -48,7 +48,7 @@ import org.springframework.util.Assert;
/**
* {@link ExpirationConfiguration} is a Spring {@link Configuration} class used to configure expiration policies
* for GemFire/Geode {@link Region Regions}.
* for Pivotal GemFire/Apache Geode {@link Region Regions}.
*
* @author John Blum
* @see org.springframework.context.annotation.Configuration

View File

@@ -36,7 +36,7 @@ import org.springframework.transaction.annotation.EnableTransactionManagement;
/**
* The {@link GemFireAsLastResourceConfiguration} class is a Spring {@link Configuration @Configuration}
* annotated class used to configure the GemFire "Last Resource" Spring Data GemFire {@link Aspect Aspects}.
* annotated class used to configure the Pivotal GemFire "Last Resource" SDG {@link Aspect Aspects}.
*
* @author John Blum
* @see org.apache.geode.cache.GemFireCache
@@ -50,7 +50,7 @@ import org.springframework.transaction.annotation.EnableTransactionManagement;
* @see org.springframework.data.gemfire.config.annotation.support.GemFireAsLastResourceConnectionAcquiringAspect
* @see org.springframework.data.gemfire.config.annotation.support.GemFireAsLastResourceConnectionClosingAspect
* @see org.springframework.transaction.annotation.EnableTransactionManagement
* @since 1.0.0
* @since 2.0.0
*/
@Configuration
@SuppressWarnings("unused")

View File

@@ -25,7 +25,7 @@ import org.springframework.data.gemfire.util.PropertiesBuilder;
/**
* The {@link GemFirePropertiesConfiguration} class is a Spring {@link org.springframework.context.annotation.ImportBeanDefinitionRegistrar}
* capable of configuring additional GemFire Properties on a (Spring Boot) application class at runtime
* capable of configuring additional Pivotal GemFire Properties on a (Spring Boot) application class at runtime
* during startup.
*
* @author John Blum

View File

@@ -53,7 +53,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link IndexConfiguration} class is a Spring {@link org.springframework.context.annotation.ImportBeanDefinitionRegistrar}
* and extension of {@link EntityDefinedRegionsConfiguration} used in the {@link EnableIndexing} annotation
* to dynamically create GemFire/Geode {@link org.apache.geode.cache.Region} {@link Index Indexes} based on
* to dynamically create Pivotal GemFire/Apache Geode {@link org.apache.geode.cache.Region} {@link Index Indexes} based on
* {@link GemfirePersistentEntity} {@link GemfirePersistentProperty} annotations.
*
* @author John Blum

View File

@@ -25,8 +25,8 @@ import org.springframework.data.gemfire.util.PropertiesBuilder;
/**
* The {@link McastConfiguration} class is a Spring {@link org.springframework.context.annotation.ImportBeanDefinitionRegistrar}
* that applies additional GemFire configuration by way of GemFire System properties to configure and use
* multi-cast networking for GemFire communication and distribution rather than the (preferred)
* that applies additional Pivotal GemFire configuration by way of Pivotal GemFire System properties to configure and use
* multi-cast networking for Pivotal GemFire communication and distribution rather than the (preferred)
* Locator-based location services.
*
* @author John Blum

View File

@@ -24,6 +24,7 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.control.ResourceManager;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.annotation.Configuration;
@@ -31,8 +32,8 @@ import org.springframework.context.annotation.Import;
import org.springframework.data.gemfire.support.GemfireBeanFactoryLocator;
/**
* The {@link PeerCacheApplication} annotation enables an embedded GemFire peer {@link org.apache.geode.cache.Cache}
* instance in a Spring Data GemFire based application.
* The {@link PeerCacheApplication} annotation enables an embedded Pivotal GemFire peer {@link Cache} instance
* in a SDG based application.
*
* @author John Blum
* @see org.apache.geode.cache.control.ResourceManager
@@ -81,7 +82,7 @@ public @interface PeerCacheApplication {
float criticalOffHeapPercentage() default 0.0f;
/**
* By default, a GemFire member (both locators and servers) will attempt to reconnect and reinitialize the cache
* By default, a Pivotal GemFire member (both locators and servers) will attempt to reconnect and reinitialize the cache
* after it has been forced out of the distributed system by a network partition event or has otherwise been
* shunned by other members. Use this property to enable the auto-reconnect behavior.
*
@@ -139,7 +140,7 @@ public @interface PeerCacheApplication {
int lockTimeout() default 60;
/**
* Configures the log level used to output log messages at GemFire cache runtime.
* Configures the log level used to output log messages at Pivotal GemFire cache runtime.
*
* Defaults to {@literal config}.
*
@@ -159,7 +160,7 @@ public @interface PeerCacheApplication {
int messageSyncInterval() default 1;
/**
* Configures the name of this GemFire member in the cluster (distributed system).
* Configures the name of this Pivotal GemFire member in the cluster (distributed system).
*
* Defaults to {@literal SpringBasedPeerCacheApplication}.
*
@@ -179,8 +180,8 @@ public @interface PeerCacheApplication {
/**
* Determines whether the {@link GemfireBeanFactoryLocator} should be enabled to lookup
* the Spring {@link BeanFactory} to auto-wire and configure/initialize GemFire components
* created in a non-Spring managed, GemFire context.
* the Spring {@link BeanFactory} to auto-wire and configure/initialize Pivotal GemFire components
* created in a non-Spring managed, Pivotal GemFire context.
*
* Defaults to {@literal false}.
*
@@ -189,7 +190,7 @@ public @interface PeerCacheApplication {
boolean useBeanFactoryLocator() default false;
/**
* Configures whether this GemFire cache member node would pull it's configuration meta-data
* Configures whether this Pivotal GemFire cache member node would pull it's configuration meta-data
* from the cluster-based Cluster Configuration service.
*
* Defaults to {@literal false}.

View File

@@ -26,7 +26,7 @@ import java.lang.annotation.Target;
/**
* {@link UsesGemFireProperties} is a meta-annotation used to mark other SDG {@link Annotation Annotations}
* that uses GemFire properties to configure the Spring-based GemFire cache instance.
* that uses Pivotal GemFire properties to configure the Spring-based Pivotal GemFire cache instance.
*
* @author John Blum
* @see java.lang.annotation.Annotation

View File

@@ -61,9 +61,8 @@ import org.springframework.util.ClassUtils;
import org.springframework.util.StringUtils;
/**
* The {@link AbstractAnnotationConfigSupport} class is an abstract base class encapsulating functionality
* common to all Annotations and configuration classes used to configure Pivotal GemFire/Apache Geode objects
* with Spring Data GemFire or Spring Data Geode.
* The {@link AbstractAnnotationConfigSupport} class is an abstract base class encapsulating functionality common to
* all Annotations and configuration classes used to configure Pivotal GemFire/Apache Geode objects with SDG.
*
* @author John Blum
* @see java.lang.ClassLoader
@@ -194,7 +193,7 @@ public abstract class AbstractAnnotationConfigSupport
}
/**
* Constructs a new instance of {@link Log} to log statements printed by Spring Data GemFire/Geode.
* Constructs a new instance of {@link Log} to log statements printed by SDG.
*
* @return a new instance of {@link Log}.
* @see org.apache.commons.logging.LogFactory#getLog(Class)

View File

@@ -30,7 +30,7 @@ import org.springframework.data.gemfire.support.WiringDeclarableSupport;
/**
* The {@link AbstractAuthInitialize} class is an abstract support class and basic implementation
* of the {@link AuthInitialize} interface used in the authentication of a client or peer
* with a secure GemFire/Geode cluster.
* with a secure Pivotal GemFire/Apache Geode cluster.
*
* @author John Blum
* @see java.util.Properties

View File

@@ -44,7 +44,7 @@ import org.springframework.util.StringUtils;
/**
* {@link AbstractGemFireAsLastResourceAspectSupport} is an abstract base class encapsulating functionality common
* to all AOP Aspect extensions/implementations involving the GemFire JCA ResourceAdapter object registered in
* to all AOP Aspect extensions/implementations involving the Pivotal GemFire JCA ResourceAdapter object registered in
* the JNDI context of a managed environment.
*
* @author John Blum
@@ -111,10 +111,10 @@ public class AbstractGemFireAsLastResourceAspectSupport implements Ordered {
}
/**
* Returns the configured reference to GemFire's JCA ResourceAdapter registered in the managed environment's
* Returns the configured reference to Pivotal GemFire's JCA ResourceAdapter registered in the managed environment's
* JNDI context.
*
* @return a {@link String} containing the configured reference to GemFire's JCA ResourceAdapter
* @return a {@link String} containing the configured reference to Pivotal GemFire's JCA ResourceAdapter
* registered in the managed environment's JNDI context.
*/
public String getGemFireJcaResourceAdapterJndiName() {
@@ -456,7 +456,7 @@ public class AbstractGemFireAsLastResourceAspectSupport implements Ordered {
* Resolves a reference to the {@link GemFireCache} required by this Aspect to perform its function.
*
* This method either returns the configured {@link GemFireCache} instance or looks up
* the {@link GemFireCache} instance using GemFire's API.
* the {@link GemFireCache} instance using Pivotal GemFire's API.
*
* @return a reference to the resolved {@link GemFireCache} instance.
* @see org.springframework.data.gemfire.GemfireUtils#resolveGemFireCache()
@@ -475,10 +475,10 @@ public class AbstractGemFireAsLastResourceAspectSupport implements Ordered {
}
/**
* Resolves the configured JNDI name used to lookup and resolve the GemFire JCA ResourceAdapter object
* Resolves the configured JNDI name used to lookup and resolve the Pivotal GemFire JCA ResourceAdapter object
* from the JNDI context in the managed environment.
*
* @return a {@link String} containing the JNDI name used to lookup and resolve the GemFire JCA ResourceAdapter
* @return a {@link String} containing the JNDI name used to lookup and resolve the Pivotal GemFire JCA ResourceAdapter
* object from the JNDI context in the managed environment.
* @see #getGemFireJcaResourceAdapterJndiName()
*/
@@ -525,7 +525,7 @@ public class AbstractGemFireAsLastResourceAspectSupport implements Ordered {
catch (ResourceException cause) {
String message =
String.format("Failed to acquire GemFire Connection from GemFire's JCA ResourceAdapter: %s",
String.format("Failed to acquire Pivotal GemFire Connection from GemFire's JCA ResourceAdapter: %s",
cause.getMessage());
if (throwOnError) {
@@ -562,7 +562,7 @@ public class AbstractGemFireAsLastResourceAspectSupport implements Ordered {
}
catch (ResourceException cause) {
String message = String.format("Failed to close GemFire Connection: %s", cause.getMessage());
String message = String.format("Failed to close Pivotal GemFire Connection: %s", cause.getMessage());
if (throwOnError) {
throw newRuntimeException(cause, message);

View File

@@ -70,7 +70,7 @@ public abstract class EmbeddedServiceConfigurationSupport extends AbstractAnnota
/**
* Returns a reference to an instance of the {@link AbstractCacheConfiguration} class used to configure
* a GemFire (Singleton, client or peer) cache instance along with it's associated, embedded services.
* a Pivotal GemFire (Singleton, client or peer) cache instance along with it's associated, embedded services.
*
* @param <T> {@link Class} type extension of {@link AbstractCacheConfiguration}.
* @return a reference to a single {@link AbstractCacheConfiguration} instance.
@@ -233,14 +233,14 @@ public abstract class EmbeddedServiceConfigurationSupport extends AbstractAnnota
/**
* Constructs a new instance of the {@link GemFirePropertiesBeanPostProcessor} initialized with
* the given GemFire/Geode {@link Properties}.
* the given Pivotal GemFire/Apache Geode {@link Properties}.
*
* @param gemfireProperties {@link Properties} used to configure Pivotal GemFire or Apache Geode.
* @throws IllegalArgumentException if {@link Properties} are {@literal null} or empty.
* @see java.util.Properties
*/
protected GemFirePropertiesBeanPostProcessor(Properties gemfireProperties) {
Assert.notEmpty(gemfireProperties, "GemFire Properties are required");
Assert.notEmpty(gemfireProperties, "Pivotal GemFire Properties are required");
this.gemfireProperties = gemfireProperties;
}

View File

@@ -27,7 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired;
/**
* The {@link GemFireAsLastResourceConnectionAcquiringAspect} class is a {@link AbstractGemFireAsLastResourceAspectSupport}
* implementation responsible for acquiring a GemFire Connection from GemFire's JCA ResourceAdapter,
* implementation responsible for acquiring a Pivotal GemFire Connection from Pivotal GemFire's JCA ResourceAdapter,
* {@link GFConnectionFactory} after a CMT/JTA Transaction is began, which is initiated by
* Spring's Transaction infrastructure.
*
@@ -48,18 +48,17 @@ public class GemFireAsLastResourceConnectionAcquiringAspect extends AbstractGemF
private GFConnectionFactory gemfireConnectionFactory;
/**
* Acquires (opens) a GemFire JCA ResourceAdapter Connection after the Spring CMT/JTA Transaction begins.
* Acquires (opens) a Pivotal GemFire JCA ResourceAdapter Connection after the Spring CMT/JTA Transaction begins.
*/
@Before("atTransactionalType() || atTransactionalMethod()")
public void doGemFireConnectionFactoryGetConnection() {
logTraceInfo("Acquiring GemFire Connection from GemFire JCA ResourceAdapter registered at [%s]...",
logTraceInfo("Acquiring Pivotal GemFire Connection from Pivotal GemFire JCA ResourceAdapter registered at [%s]...",
resolveGemFireJcaResourceAdapterJndiName());
GemFireConnectionHolder.acquire(resolveGemFireConnectionFactory(), isThrowOnError(), this::logError);
}
/* (non-Javadoc) */
synchronized GFConnectionFactory resolveGemFireConnectionFactory() {
GFConnectionFactory connectionFactory = getGemFireConnectionFactory();

View File

@@ -21,8 +21,8 @@ import org.aspectj.lang.annotation.Aspect;
/**
* The {@link GemFireAsLastResourceConnectionClosingAspect} class is a {@link AbstractGemFireAsLastResourceAspectSupport}
* implementation responsible for closing the GemFire Connection obtained from the GemFire JCA ResourceAdapter
* deployed in a managed environment when using GemFire as the Last Resource in a CMT/JTA Transaction
* implementation responsible for closing the Pivotal GemFire Connection obtained from the Pivotal GemFire JCA ResourceAdapter
* deployed in a managed environment when using Pivotal GemFire as the Last Resource in a CMT/JTA Transaction
* initiated from Spring's Transaction infrastructure.
*
* @author John Blum
@@ -38,12 +38,12 @@ public class GemFireAsLastResourceConnectionClosingAspect extends AbstractGemFir
private static final int DEFAULT_ORDER = 1024000;
/**
* Closes the GemFire JCA ResourceAdapter Connection after the Spring CMT/JTA Transaction completes.
* Closes the Pivotal GemFire JCA ResourceAdapter Connection after the Spring CMT/JTA Transaction completes.
*/
@After("atTransactionalType() || atTransactionalMethod()")
public void doGemFireConnectionClose() {
logTraceInfo("Closing GemFire Connection...");
logTraceInfo("Closing Pivotal GemFire Connection...");
GemFireConnectionHolder.close(isThrowOnError(), this::logWarning);
}

View File

@@ -43,7 +43,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link GemFireComponentClassTypeScanner} class is a classpath component scanner used to search
* for GemFire components based on {@link Class} type.
* for Pivotal GemFire components based on {@link Class} type.
*
* @author John Blum
* @see java.lang.Iterable
@@ -60,7 +60,7 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
* Factory method to construct an instance of the {@link GemFireComponentClassTypeScanner} initialized with
* the given array of base packages to scan.
*
* @param basePackages array of base packages to scan for GemFire components.
* @param basePackages array of base packages to scan for Pivotal GemFire components.
* @throws IllegalArgumentException if the array of base packages is {@literal null} or empty.
* @return an initialized instance of {@link GemFireComponentClassTypeScanner}.
* @see #GemFireComponentClassTypeScanner(Set)
@@ -73,7 +73,7 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
* Factory method to construct an instance of the {@link GemFireComponentClassTypeScanner} initialized with
* the given {@link Iterable} of base packages to scan.
*
* @param basePackages {@link Iterable} of base packages to scan for GemFire components.
* @param basePackages {@link Iterable} of base packages to scan for Pivotal GemFire components.
* @throws IllegalArgumentException if the {@link Iterable} of base packages is {@literal null} or empty.
* @return an initialized instance of {@link GemFireComponentClassTypeScanner}.
* @see #GemFireComponentClassTypeScanner(Set)
@@ -98,7 +98,7 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
* Constructs an instance of the {@link GemFireComponentClassTypeScanner} initialized with
* the given {@link Set} of base packages to scan.
*
* @param basePackages {@link Set} of base packages to scan for GemFire component clases.
* @param basePackages {@link Set} of base packages to scan for Pivotal GemFire component clases.
* @throws IllegalArgumentException if the {@link Set} is {@literal null} or empty.
* @see java.util.Set
*/
@@ -118,9 +118,9 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
}
/**
* Returns an unmodifiable {@link Set} of base packages to scan for GemFire components.
* Returns an unmodifiable {@link Set} of base packages to scan for Pivotal GemFire components.
*
* @return an unmodifiable {@link Set} of base packages to scan for GemFire components.
* @return an unmodifiable {@link Set} of base packages to scan for Pivotal GemFire components.
* @see java.util.Set
*/
protected Set<String> getBasePackages() {
@@ -128,10 +128,10 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
}
/**
* Returns a reference to the {@link ClassLoader} used to find and load GemFire application
* Returns a reference to the {@link ClassLoader} used to find and load Pivotal GemFire application
* persistent entity classes.
*
* @return the {@link ClassLoader} used to find and load GemFire application persistent entity classes.
* @return the {@link ClassLoader} used to find and load Pivotal GemFire application persistent entity classes.
* @see org.springframework.beans.factory.config.ConfigurableBeanFactory#getBeanClassLoader()
* @see java.lang.Thread#getContextClassLoader()
* @see java.lang.ClassLoader
@@ -147,7 +147,7 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
}
/**
* Returns a reference to the Spring {@link Environment} in which the Spring GemFire application is running.
* Returns a reference to the Spring {@link Environment} in which the Spring Pivotal GemFire application is running.
*
* @return a reference to the Spring {@link Environment}.
* @see org.springframework.context.ApplicationContext#getEnvironment()
@@ -192,10 +192,10 @@ public class GemFireComponentClassTypeScanner implements Iterable<String> {
}
/**
* Scans the {@link Set} of base packages searching for GemFire application components
* Scans the {@link Set} of base packages searching for Pivotal GemFire application components
* accepted by the filters of this scanner.
*
* @return a {@link Set} of GemFire application component {@link Class} types found on the classpath.
* @return a {@link Set} of Pivotal GemFire application component {@link Class} types found on the classpath.
* @see #newClassPathScanningCandidateComponentProvider(boolean)
* @see java.util.Set
*/

View File

@@ -45,7 +45,7 @@ public abstract class SchemaObjectDefinition implements Serializable, Ordered {
/**
* Constructs a new instance of {@link SchemaObjectDefinition} initialized with the specified {@link String name}.
*
* @param name {@link String name} given to the GemFire/Geode schema object; must not be {@literal null}.
* @param name {@link String name} given to the Pivotal GemFire/Apache Geode schema object; must not be {@literal null}.
* @throws IllegalArgumentException if name is not specified.
*/
public SchemaObjectDefinition(String name) {

View File

@@ -32,8 +32,8 @@ import org.apache.geode.cache.wan.GatewaySender;
/**
* {@link SchemaObjectType} defines an enumeration of all the types of Apache Geode or Pivotal GemFire schema objects
* (e.g. {@link Region}) that may possibly be handled by Spring Data Geode / Spring Data GemFire
* and that can be created remotely, from a client application.
* (e.g. {@link Region}) that may possibly be handled by SDG and that can be created remotely,
* from a client application.
*
* @author John Blum
* @see org.apache.geode.cache.asyncqueue.AsyncEventQueue
@@ -69,9 +69,9 @@ public enum SchemaObjectType {
/**
* Constructs an instance of an {@link SchemaObjectType} enumerated value initialized with
* the actual GemFire {@link Class schema object instance type}.
* the actual Pivotal GemFire {@link Class schema object instance type}.
*
* @param objectType actual {@link Class interface type} of the GemFire schema object instance.
* @param objectType actual {@link Class interface type} of the Pivotal GemFire schema object instance.
* @see java.lang.Class
*/
SchemaObjectType(Class<?> objectType) {
@@ -80,13 +80,13 @@ public enum SchemaObjectType {
/**
* Null-safe factory method used to look up and resolve the corresponding {@link SchemaObjectType}
* given an instance of a GemFire schema object.
* given an instance of a Pivotal GemFire schema object.
*
* For example, given an instance of {@link Region}, this factory method will return
* {@link SchemaObjectType#REGION}.
*
* @param obj actual instance of a GemFire schema object, e.g. reference to a {@link Region}.
* @return a corresponding {@link SchemaObjectType} for a given instance of a GemFire schema object.
* @param obj actual instance of a Pivotal GemFire schema object, e.g. reference to a {@link Region}.
* @return a corresponding {@link SchemaObjectType} for a given instance of a Pivotal GemFire schema object.
* If the type cannot be determined, then {@link SchemaObjectType#UNKNOWN} is returned.
* @see #from(Class)
*/
@@ -98,13 +98,13 @@ public enum SchemaObjectType {
/**
* Null-safe factory method used to look up and resolve the corresponding {@link SchemaObjectType}
* given the type of GemFire schema object.
* given the type of Pivotal GemFire schema object.
*
* For example, given the {@link Region} {@link Class interface} or any {@link Class sub-type} of {@link Region},
* this factory method will return {@link SchemaObjectType#REGION}.
*
* @param type {@link Class type} of the GemFire schema object, e.g. the {@link Region} {@link Class interface}.
* @return a corresponding {@link SchemaObjectType} for a given {@link Class type }of a GemFire schema object.
* @param type {@link Class type} of the Pivotal GemFire schema object, e.g. the {@link Region} {@link Class interface}.
* @return a corresponding {@link SchemaObjectType} for a given {@link Class type }of a Pivotal GemFire schema object.
* If the type cannot be determined, then {@link SchemaObjectType#UNKNOWN} is returned.
* @see #from(Object)
*/
@@ -115,9 +115,9 @@ public enum SchemaObjectType {
}
/**
* Returns the {@link Class class type} of the GemFire schema object represented by this enumerated value.
* Returns the {@link Class class type} of the Pivotal GemFire schema object represented by this enumerated value.
*
* @return the {@link Class class type} of the GemFire schema object represented by this enumerated value.
* @return the {@link Class class type} of the Pivotal GemFire schema object represented by this enumerated value.
* @see java.lang.Class
*/
public Class<?> getObjectType() {

View File

@@ -38,8 +38,8 @@ import org.springframework.util.StringUtils;
* a {@link GemFireCache} by registering all cache {@link Region Regions} that have not been explicitly defined
* in the Spring application context.
*
* This is usually the case for {@link Region Regions} that have been defined in GemFire's native {@literal cache.xml}
* or defined using GemFire Cluster-based Configuration Service.
* This is usually the case for {@link Region Regions} that have been defined in Pivotal GemFire's
* native {@literal cache.xml} or defined using Pivotal GemFire's Cluster Configuration Service.
*
* @author John Blum
* @see org.apache.geode.cache.GemFireCache
@@ -67,7 +67,6 @@ public class AutoRegionLookupBeanPostProcessor implements BeanPostProcessor, Bea
this.beanFactory = (ConfigurableListableBeanFactory) beanFactory;
}
/* (non-Javadoc) */
protected ConfigurableListableBeanFactory getBeanFactory() {
return Optional.ofNullable(this.beanFactory).orElseThrow(() ->
newIllegalStateException("BeanFactory was not properly configured"));
@@ -86,12 +85,10 @@ public class AutoRegionLookupBeanPostProcessor implements BeanPostProcessor, Bea
return bean;
}
/* (non-Javadoc) */
void registerCacheRegionsAsBeans(GemFireCache cache) {
cache.rootRegions().forEach(this::registerCacheRegionAsBean);
}
/* (non-Javadoc) */
void registerCacheRegionAsBean(Region<?, ?> region) {
if (region != null) {
@@ -108,7 +105,6 @@ public class AutoRegionLookupBeanPostProcessor implements BeanPostProcessor, Bea
}
}
/* (non-Javadoc) */
String getBeanName(Region region) {
return Optional.ofNullable(region.getFullPath())
@@ -117,7 +113,6 @@ public class AutoRegionLookupBeanPostProcessor implements BeanPostProcessor, Bea
.orElseGet(region::getName);
}
/* (non-Javadoc) */
Set<Region<?, ?>> nullSafeSubregions(Region<?, ?> parentRegion) {
return Optional.ofNullable(parentRegion.subregions(false)).orElse(Collections.emptySet());
}

View File

@@ -35,9 +35,9 @@ import org.springframework.util.StringUtils;
/**
* {@link ClientRegionPoolBeanFactoryPostProcessor} is a Spring {@link BeanFactoryPostProcessor} implementation
* ensuring a proper dependency is declared between a GemFire client {@link org.apache.geode.cache.Region}
* and the GemFire client {@link org.apache.geode.cache.client.Pool} it references and uses, providing
* the GemFire client {@link org.apache.geode.cache.client.Pool} has been defined and configured with
* ensuring a proper dependency is declared between a Pivotal GemFire client {@link org.apache.geode.cache.Region}
* and the Pivotal GemFire client {@link org.apache.geode.cache.client.Pool} it references and uses, providing
* the Pivotal GemFire client {@link org.apache.geode.cache.client.Pool} has been defined and configured with
* Spring (Data GemFire) configuration meta-data (e.g. XML).
*
* @author John Blum

View File

@@ -16,6 +16,7 @@
package org.springframework.data.gemfire.config.support;
import java.beans.PropertyEditor;
import java.beans.PropertyEditorSupport;
import org.apache.geode.cache.EvictionAction;
@@ -48,9 +49,9 @@ import org.springframework.data.gemfire.wan.OrderPolicyConverter;
/**
* {@link CustomEditorBeanFactoryPostProcessor} is a Spring {@link BeanFactoryPostProcessor} implementation
* used to register custom {@link java.beans.PropertyEditor PropertyEditors} / Spring {@link Converter Converters}
* that are used to perform type conversions between String-based configuration meta-data and actual GemFire
* or Spring Data GemFire defined (enumerated) types.
* used to register custom {@link PropertyEditor PropertyEditors} / Spring {@link Converter Converters}
* that are used to perform type conversions between String-based configuration meta-data
* and actual Pivotal GemFire or SDG defined types.
*
* @author John Blum
* @see org.springframework.beans.factory.config.BeanFactoryPostProcessor

View File

@@ -29,7 +29,7 @@ import org.springframework.data.gemfire.config.xml.GemfireConstants;
/**
* {@link DefinedIndexesApplicationListener} is a Spring {@link ApplicationListener} used to create all
* "defined" GemFire {@link org.apache.geode.cache.query.Index Indexes} by using the {@link QueryService},
* "defined" Pivotal GemFire {@link org.apache.geode.cache.query.Index Indexes} by using the {@link QueryService},
* {@literal defineXxxIndex(..)} methods.
*
* @author John Blum

Some files were not shown because too many files have changed in this diff Show More