the Region value class type.
* @param region the GemFire Cache Region to create a proxy for.
* @return the Region proxy implementing all interfaces implemented by the passed-in Region object.
- * @see com.gemstone.gemfire.cache.Region#close()
+ * @see org.apache.geode.cache.Region#close()
* @see #execute(GemfireCallback, boolean)
*/
@SuppressWarnings("unchecked")
@@ -500,7 +499,7 @@ public class GemfireTemplate extends GemfireAccessor implements GemfireOperation
/**
* InvocationHandler that suppresses close calls on GemFire Cache Regions.
*
- * @see com.gemstone.gemfire.cache.Region#close()
+ * @see org.apache.geode.cache.Region#close()
* @see java.lang.reflect.InvocationHandler
*/
private static class RegionCloseSuppressingInvocationHandler implements InvocationHandler {
diff --git a/src/main/java/org/springframework/data/gemfire/GemfireTransactionManager.java b/src/main/java/org/springframework/data/gemfire/GemfireTransactionManager.java
index 8cf37f57..9cb0a818 100644
--- a/src/main/java/org/springframework/data/gemfire/GemfireTransactionManager.java
+++ b/src/main/java/org/springframework/data/gemfire/GemfireTransactionManager.java
@@ -16,6 +16,9 @@
package org.springframework.data.gemfire;
+import org.apache.geode.cache.Cache;
+import org.apache.geode.cache.CacheTransactionManager;
+import org.apache.geode.cache.Region;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.transaction.CannotCreateTransactionException;
import org.springframework.transaction.NoTransactionException;
@@ -28,38 +31,34 @@ import org.springframework.transaction.support.ResourceTransactionManager;
import org.springframework.transaction.support.TransactionSynchronizationManager;
import org.springframework.util.Assert;
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheTransactionManager;
-import com.gemstone.gemfire.cache.Region;
-
/**
* Local transaction manager for GemFire Enterprise Fabric (GEF). Provides a
* {@link PlatformTransactionManager} implementation for a single GemFire
* {@link CacheTransactionManager}.
- *
+ *
* Binds one or multiple GemFire regions for the specified {@link Cache} to the
* thread, potentially allowing for one region per cache model.
- *
+ *
*
* This local strategy is an alternative to executing cache operations within
* JTA transactions. Its advantage is that is able to work in any environment,
* for example a stand-alone application or a test suite. It is not able
* to provide XA transactions, for example to share transactions with data
* access.
- *
+ *
*
* To prevent dirty reads, by default, the cache is configured to return copies
* rather then direct references for get operations. As a
* workaround, one could use explicitly deep copy objects before making changes
* to them to avoid unnecessary copying on every fetch.
- *
- * @see com.gemstone.gemfire.cache.CacheTransactionManager
- * @see com.gemstone.gemfire.cache.Cache#setCopyOnRead(boolean)
- * @see com.gemstone.gemfire.cache.Region#get(Object)
- * @see com.gemstone.gemfire.CopyHelper#copy(Object)
+ *
+ * @see org.apache.geode.cache.CacheTransactionManager
+ * @see org.apache.geode.cache.Cache#setCopyOnRead(boolean)
+ * @see org.apache.geode.cache.Region#get(Object)
+ * @see org.apache.geode.CopyHelper#copy(Object)
* @see #setCopyOnRead(boolean)
* @see org.springframework.transaction.support.AbstractPlatformTransactionManager
- *
+ *
* @author Costin Leau
*/
// TODO add lenient behavior if a transaction is already started on the current
@@ -80,7 +79,7 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
/**
* Creates a new GemfireTransactionManager instance.
- *
+ *
* @param cache a reference to the GemFire Cache associated with Cache transactions.
*/
public GemfireTransactionManager(Cache cache) {
@@ -147,8 +146,8 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
throw new NoTransactionException(
"No transaction associated with the current thread; are there multiple transaction managers ?", ex);
}
-
- catch (com.gemstone.gemfire.cache.TransactionException ex) {
+
+ catch (org.apache.geode.cache.TransactionException ex) {
throw new GemfireTransactionCommitException("Unexpected failure on commit of Cache local transaction", ex);
}
}
@@ -189,7 +188,7 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
/**
* Returns the Cache that this instance manages local transactions for.
- *
+ *
* @return Gemfire cache
*/
public Cache getCache() {
@@ -198,7 +197,7 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
/**
* Sets the Cache that this instance manages local transactions for.
- *
+ *
* @param cache Gemfire cache
*/
public void setCache(Cache cache) {
@@ -229,11 +228,11 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
* concurrent threads in the same VM, whether or not transactions are used.
*
* One could explicitly deep copy objects before making changes (for example
- * by using {@link com.gemstone.gemfire.CopyHelper#copy(Object)} in which
+ * by using {@link org.apache.geode.CopyHelper#copy(Object)} in which
* case this setting can be set to false. However, unless there
* is a measurable performance penalty, the recommendation is to keep this
* setting to true
- *
+ *
* @param copyOnRead whether copies (default) rather then direct references
* will be returned on fetch operations
*/
@@ -243,7 +242,7 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
/**
* Indicates whether copy on read is set or not on the transaction manager.
- *
+ *
* @see #setCopyOnRead(boolean)
* @return the copyOnRead
*/
@@ -253,7 +252,7 @@ public class GemfireTransactionManager extends AbstractPlatformTransactionManage
/**
* GemfireTM local transaction object.
- *
+ *
* @author Costin Leau
*/
private static class CacheTransactionObject {
diff --git a/src/main/java/org/springframework/data/gemfire/GemfireUtils.java b/src/main/java/org/springframework/data/gemfire/GemfireUtils.java
index 006f59e2..b237098c 100644
--- a/src/main/java/org/springframework/data/gemfire/GemfireUtils.java
+++ b/src/main/java/org/springframework/data/gemfire/GemfireUtils.java
@@ -16,22 +16,21 @@
package org.springframework.data.gemfire;
+import org.apache.geode.cache.CacheFactory;
+import org.apache.geode.internal.GemFireVersion;
import org.springframework.data.gemfire.config.support.GemfireFeature;
import org.springframework.data.gemfire.util.CacheUtils;
import org.springframework.util.ClassUtils;
import org.w3c.dom.Element;
-import com.gemstone.gemfire.cache.CacheFactory;
-import com.gemstone.gemfire.internal.GemFireVersion;
-
/**
* GemfireUtils is an abstract utility class encapsulating common functionality to access features and capabilities
* of GemFire based on version and other configuration meta-data.
*
* @author John Blum
* @see org.springframework.data.gemfire.util.DistributedSystemUtils
- * @see com.gemstone.gemfire.cache.CacheFactory
- * @see com.gemstone.gemfire.cache.Region
+ * @see org.apache.geode.cache.CacheFactory
+ * @see org.apache.geode.cache.Region
* @since 1.3.3
*/
public abstract class GemfireUtils extends CacheUtils {
@@ -40,13 +39,13 @@ public abstract class GemfireUtils extends CacheUtils {
public final static String GEMFIRE_VERSION = CacheFactory.getVersion();
private static final String ASYNC_EVENT_QUEUE_ELEMENT_NAME = "async-event-queue";
- private static final String ASYNC_EVENT_QUEUE_TYPE_NAME = "com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue";
+ private static final String ASYNC_EVENT_QUEUE_TYPE_NAME = "org.apache.geode.cache.asyncqueue.AsyncEventQueue";
private static final String CQ_ELEMENT_NAME = "cq-listener-container";
- private static final String CQ_TYPE_NAME = "com.gemstone.gemfire.cache.query.internal.cq.CqServiceFactoryImpl";
+ private static final String CQ_TYPE_NAME = "org.apache.geode.cache.query.internal.cq.CqServiceFactoryImpl";
private static final String GATEWAY_RECEIVER_ELEMENT_NAME = "gateway-receiver";
- private static final String GATEWAY_RECEIVER_TYPE_NAME = "com.gemstone.gemfire.internal.cache.wan.GatewayReceiverFactoryImpl";
+ private static final String GATEWAY_RECEIVER_TYPE_NAME = "org.apache.geode.internal.cache.wan.GatewayReceiverFactoryImpl";
private static final String GATEWAY_SENDER_ELEMENT_NAME = "gateway-sender";
- private static final String GATEWAY_SENDER_TYPE_NAME = "com.gemstone.gemfire.internal.cache.wan.GatewaySenderFactoryImpl";
+ private static final String GATEWAY_SENDER_TYPE_NAME = "org.apache.geode.internal.cache.wan.GatewaySenderFactoryImpl";
/* (non-Javadoc) */
public static boolean isClassAvailable(String fullyQualifiedClassName) {
diff --git a/src/main/java/org/springframework/data/gemfire/IndexFactoryBean.java b/src/main/java/org/springframework/data/gemfire/IndexFactoryBean.java
index a346dad8..0b8c6005 100644
--- a/src/main/java/org/springframework/data/gemfire/IndexFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/IndexFactoryBean.java
@@ -18,6 +18,15 @@ package org.springframework.data.gemfire;
import java.util.Collection;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.RegionService;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.query.Index;
+import org.apache.geode.cache.query.IndexExistsException;
+import org.apache.geode.cache.query.IndexInvalidException;
+import org.apache.geode.cache.query.IndexNameConflictException;
+import org.apache.geode.cache.query.IndexStatistics;
+import org.apache.geode.cache.query.QueryService;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
@@ -31,16 +40,6 @@ import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.RegionService;
-import com.gemstone.gemfire.cache.client.ClientCache;
-import com.gemstone.gemfire.cache.query.Index;
-import com.gemstone.gemfire.cache.query.IndexExistsException;
-import com.gemstone.gemfire.cache.query.IndexInvalidException;
-import com.gemstone.gemfire.cache.query.IndexNameConflictException;
-import com.gemstone.gemfire.cache.query.IndexStatistics;
-import com.gemstone.gemfire.cache.query.QueryService;
-
/**
* Spring FactoryBean for easy declarative creation of GemFire Indexes.
*
@@ -52,9 +51,9 @@ import com.gemstone.gemfire.cache.query.QueryService;
* @see org.springframework.beans.factory.FactoryBean
* @see org.springframework.beans.factory.InitializingBean
* @see org.springframework.data.gemfire.IndexFactoryBean.IndexWrapper
- * @see com.gemstone.gemfire.cache.RegionService
- * @see com.gemstone.gemfire.cache.query.Index
- * @see com.gemstone.gemfire.cache.query.QueryService
+ * @see org.apache.geode.cache.RegionService
+ * @see org.apache.geode.cache.query.Index
+ * @see org.apache.geode.cache.query.QueryService
* @since 1.0.0
*/
public class IndexFactoryBean implements InitializingBean, FactoryBean, BeanNameAware, BeanFactoryAware {
@@ -466,7 +465,7 @@ public class IndexFactoryBean implements InitializingBean, FactoryBean, B
@Override
@SuppressWarnings("deprecation")
- public com.gemstone.gemfire.cache.query.IndexType getType() {
+ public org.apache.geode.cache.query.IndexType getType() {
return getIndex().getType();
}
diff --git a/src/main/java/org/springframework/data/gemfire/IndexMaintenancePolicyType.java b/src/main/java/org/springframework/data/gemfire/IndexMaintenancePolicyType.java
index 60fc9ab6..f2f5746b 100644
--- a/src/main/java/org/springframework/data/gemfire/IndexMaintenancePolicyType.java
+++ b/src/main/java/org/springframework/data/gemfire/IndexMaintenancePolicyType.java
@@ -16,16 +16,16 @@
package org.springframework.data.gemfire;
-import com.gemstone.gemfire.cache.AttributesFactory;
-import com.gemstone.gemfire.cache.RegionFactory;
+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.
*
* @author John Blum
- * @see com.gemstone.gemfire.cache.AttributesFactory#setIndexMaintenanceSynchronous(boolean)
- * @see com.gemstone.gemfire.cache.RegionAttributes#getIndexMaintenanceSynchronous()
- * @see com.gemstone.gemfire.cache.RegionFactory#setIndexMaintenanceSynchronous(boolean)
+ * @see org.apache.geode.cache.AttributesFactory#setIndexMaintenanceSynchronous(boolean)
+ * @see org.apache.geode.cache.RegionAttributes#getIndexMaintenanceSynchronous()
+ * @see org.apache.geode.cache.RegionFactory#setIndexMaintenanceSynchronous(boolean)
* @since 1.6.0
*/
@SuppressWarnings("unused")
@@ -61,7 +61,7 @@ public enum IndexMaintenancePolicyType {
*
* @param attributesFactory the AttributesFactory instance on which to set the indexMaintenanceProperty.
* @throws java.lang.NullPointerException if the AttributesFactory reference is null.
- * @see #setIndexMaintenance(com.gemstone.gemfire.cache.RegionFactory)
+ * @see #setIndexMaintenance(org.apache.geode.cache.RegionFactory)
*/
@SuppressWarnings("deprecation")
public void setIndexMaintenance(final AttributesFactory attributesFactory) {
@@ -74,7 +74,7 @@ public enum IndexMaintenancePolicyType {
*
* @param regionFactory the RegionFactory instance on which to set the indexMaintenanceProperty.
* @throws java.lang.NullPointerException if the RegionFactory reference is null.
- * @see #setIndexMaintenance(com.gemstone.gemfire.cache.AttributesFactory)
+ * @see #setIndexMaintenance(org.apache.geode.cache.AttributesFactory)
*/
public void setIndexMaintenance(final RegionFactory regionFactory) {
regionFactory.setIndexMaintenanceSynchronous(equals(SYNCHRONOUS));
diff --git a/src/main/java/org/springframework/data/gemfire/IndexType.java b/src/main/java/org/springframework/data/gemfire/IndexType.java
index d1a936eb..904c35d9 100644
--- a/src/main/java/org/springframework/data/gemfire/IndexType.java
+++ b/src/main/java/org/springframework/data/gemfire/IndexType.java
@@ -20,25 +20,25 @@ package org.springframework.data.gemfire;
* The IndexType class is an enumerated type of GemFire Index Types.
*
* @author John Blum
- * @see com.gemstone.gemfire.cache.query.IndexType
+ * @see org.apache.geode.cache.query.IndexType
* @since 1.5.2
*/
@SuppressWarnings({ "deprecation", "unused" })
public enum IndexType {
- FUNCTIONAL(com.gemstone.gemfire.cache.query.IndexType.FUNCTIONAL),
- HASH(com.gemstone.gemfire.cache.query.IndexType.HASH),
- PRIMARY_KEY(com.gemstone.gemfire.cache.query.IndexType.PRIMARY_KEY),
- KEY(com.gemstone.gemfire.cache.query.IndexType.PRIMARY_KEY);
+ FUNCTIONAL(org.apache.geode.cache.query.IndexType.FUNCTIONAL),
+ HASH(org.apache.geode.cache.query.IndexType.HASH),
+ PRIMARY_KEY(org.apache.geode.cache.query.IndexType.PRIMARY_KEY),
+ KEY(org.apache.geode.cache.query.IndexType.PRIMARY_KEY);
- private final com.gemstone.gemfire.cache.query.IndexType gemfireIndexType;
+ private final org.apache.geode.cache.query.IndexType gemfireIndexType;
/**
* Constructs an instance of the IndexType enum initialized with the given GemFire IndexType.
*
* @param gemfireIndexType the corresponding GemFire IndexType
- * @see com.gemstone.gemfire.cache.query.IndexType
+ * @see org.apache.geode.cache.query.IndexType
*/
- IndexType(final com.gemstone.gemfire.cache.query.IndexType gemfireIndexType) {
+ IndexType(final org.apache.geode.cache.query.IndexType gemfireIndexType) {
this.gemfireIndexType = gemfireIndexType;
}
@@ -82,9 +82,9 @@ public enum IndexType {
* @param gemfireIndexType the GemFire IndexType.
* @return a IndexType matching the GemFire IndexType or null if the GemFire IndexType does not match
* any IndexType in this enumeration.
- * @see com.gemstone.gemfire.cache.query.IndexType
+ * @see org.apache.geode.cache.query.IndexType
*/
- public static IndexType valueOf(final com.gemstone.gemfire.cache.query.IndexType gemfireIndexType) {
+ public static IndexType valueOf(final org.apache.geode.cache.query.IndexType gemfireIndexType) {
for (IndexType indexType : values()) {
if (indexType.getGemfireIndexType().equals(gemfireIndexType)) {
return indexType;
@@ -115,9 +115,9 @@ public enum IndexType {
* Gets the matching GemFire IndexType for this IndexType enumerated value.
*
* @return the matching GemFire IndexType.
- * @see com.gemstone.gemfire.cache.query.IndexType
+ * @see org.apache.geode.cache.query.IndexType
*/
- public com.gemstone.gemfire.cache.query.IndexType getGemfireIndexType() {
+ public org.apache.geode.cache.query.IndexType getGemfireIndexType() {
return gemfireIndexType;
}
diff --git a/src/main/java/org/springframework/data/gemfire/InterestPolicyConverter.java b/src/main/java/org/springframework/data/gemfire/InterestPolicyConverter.java
index 4e038915..4b26cb1d 100644
--- a/src/main/java/org/springframework/data/gemfire/InterestPolicyConverter.java
+++ b/src/main/java/org/springframework/data/gemfire/InterestPolicyConverter.java
@@ -16,17 +16,16 @@
package org.springframework.data.gemfire;
+import org.apache.geode.cache.InterestPolicy;
import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport;
-import com.gemstone.gemfire.cache.InterestPolicy;
-
/**
* The InterestPolicyConverter class is a Spring Converter implementation and Java PropertyEditor handling
* the conversion between Strings and GemFire InterestPolicy values.
*
* @author John Blum
* @see org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport
- * @see com.gemstone.gemfire.cache.InterestPolicy
+ * @see org.apache.geode.cache.InterestPolicy
* @since 1.6.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/InterestPolicyType.java b/src/main/java/org/springframework/data/gemfire/InterestPolicyType.java
index d754e22f..21ce6658 100644
--- a/src/main/java/org/springframework/data/gemfire/InterestPolicyType.java
+++ b/src/main/java/org/springframework/data/gemfire/InterestPolicyType.java
@@ -15,14 +15,14 @@
*/
package org.springframework.data.gemfire;
-import com.gemstone.gemfire.cache.InterestPolicy;
+import org.apache.geode.cache.InterestPolicy;
/**
* The InterestPolicyType enum is an enumeration of all the GemFire Subscription, InterestPolicy values.
*
* @author Lyndon Adams
* @author John Blum
- * @see com.gemstone.gemfire.cache.InterestPolicy
+ * @see org.apache.geode.cache.InterestPolicy
* @since 1.3.0
*/
@SuppressWarnings("unused")
@@ -38,7 +38,7 @@ public enum InterestPolicyType {
* Constructs an instance of the SubscriptionType enum initialized with the matching GemFire InterestPolicy.
*
* @param interestPolicy a GemFire InterestPolicy corresponding to this SubscriptionType.
- * @see com.gemstone.gemfire.cache.InterestPolicy
+ * @see org.apache.geode.cache.InterestPolicy
*/
InterestPolicyType(final InterestPolicy interestPolicy) {
this.interestPolicy = interestPolicy;
@@ -50,7 +50,7 @@ public enum InterestPolicyType {
* @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.
- * @see com.gemstone.gemfire.cache.InterestPolicy
+ * @see org.apache.geode.cache.InterestPolicy
*/
public static InterestPolicy getInterestPolicy(final InterestPolicyType interestPolicyType) {
return (interestPolicyType != null ? interestPolicyType.getInterestPolicy() : null);
@@ -62,7 +62,7 @@ public enum InterestPolicyType {
* @param interestPolicy the GemFire InterestPolicy used to lookup and match a SubscriptionType.
* @return a SubscriptionType enumerated value matching the given GemFire InterestPolicy
* or null if no matching value was found.
- * @see com.gemstone.gemfire.cache.InterestPolicy
+ * @see org.apache.geode.cache.InterestPolicy
* @see #getInterestPolicy()
*/
public static InterestPolicyType valueOf(final InterestPolicy interestPolicy) {
@@ -98,7 +98,7 @@ public enum InterestPolicyType {
* Returns the GemFire InterestPolicy corresponding to this SubscriptionType enumerated value.
*
* @return the GemFire InterestPolicy corresponding to this SubscriptionType.
- * @see com.gemstone.gemfire.cache.InterestPolicy
+ * @see org.apache.geode.cache.InterestPolicy
*/
public InterestPolicy getInterestPolicy() {
return interestPolicy;
diff --git a/src/main/java/org/springframework/data/gemfire/LazyWiringDeclarableSupport.java b/src/main/java/org/springframework/data/gemfire/LazyWiringDeclarableSupport.java
index 77271e7f..792667a4 100644
--- a/src/main/java/org/springframework/data/gemfire/LazyWiringDeclarableSupport.java
+++ b/src/main/java/org/springframework/data/gemfire/LazyWiringDeclarableSupport.java
@@ -19,6 +19,7 @@ package org.springframework.data.gemfire;
import java.util.Properties;
import java.util.concurrent.atomic.AtomicReference;
+import org.apache.geode.cache.Declarable;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.access.BeanFactoryReference;
@@ -33,8 +34,6 @@ import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
-import com.gemstone.gemfire.cache.Declarable;
-
/**
* The LazyWiringDeclarableSupport class is an implementation of the GemFire Declarable interface that enables support
* for wiring GemFire components with Spring bean dependencies defined in the Spring context.
@@ -51,7 +50,7 @@ import com.gemstone.gemfire.cache.Declarable;
* @see org.springframework.data.gemfire.DeclarableSupport
* @see org.springframework.data.gemfire.WiringDeclarableSupport
* @see org.springframework.data.gemfire.support.SpringContextBootstrappingInitializer
- * @see com.gemstone.gemfire.cache.Declarable
+ * @see org.apache.geode.cache.Declarable
* @since 1.3.4
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/LocalRegionFactoryBean.java b/src/main/java/org/springframework/data/gemfire/LocalRegionFactoryBean.java
index 1bd9373a..7f549305 100644
--- a/src/main/java/org/springframework/data/gemfire/LocalRegionFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/LocalRegionFactoryBean.java
@@ -15,13 +15,12 @@
*/
package org.springframework.data.gemfire;
+import org.apache.geode.cache.DataPolicy;
+import org.apache.geode.cache.RegionFactory;
+import org.apache.geode.cache.Scope;
import org.springframework.data.gemfire.support.RegionShortcutWrapper;
import org.springframework.util.Assert;
-import com.gemstone.gemfire.cache.DataPolicy;
-import com.gemstone.gemfire.cache.RegionFactory;
-import com.gemstone.gemfire.cache.Scope;
-
/**
* @author David Turanski
* @author John Blum
@@ -70,15 +69,15 @@ public class LocalRegionFactoryBean extends RegionFactoryBean {
/**
* Resolves the Data Policy used by this "local" GemFire Region (i.e. locally Scoped; Scope.LOCAL) based on the
- * enumerated value from com.gemstone.gemfire.cache.RegionShortcuts (LOCAL, LOCAL_PERSISTENT, LOCAL_HEAP_LRU,
+ * 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 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.
- * @see com.gemstone.gemfire.cache.DataPolicy
- * @see com.gemstone.gemfire.cache.RegionFactory
- * @see com.gemstone.gemfire.cache.RegionShortcut
+ * @see org.apache.geode.cache.DataPolicy
+ * @see org.apache.geode.cache.RegionFactory
+ * @see org.apache.geode.cache.RegionShortcut
*/
@Override
protected void resolveDataPolicy(RegionFactory regionFactory, Boolean persistent, String dataPolicy) {
diff --git a/src/main/java/org/springframework/data/gemfire/LookupRegionFactoryBean.java b/src/main/java/org/springframework/data/gemfire/LookupRegionFactoryBean.java
index 2a57dc35..db8bff37 100644
--- a/src/main/java/org/springframework/data/gemfire/LookupRegionFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/LookupRegionFactoryBean.java
@@ -16,27 +16,26 @@
package org.springframework.data.gemfire;
+import org.apache.geode.cache.AttributesMutator;
+import org.apache.geode.cache.CacheListener;
+import org.apache.geode.cache.CacheLoader;
+import org.apache.geode.cache.CacheWriter;
+import org.apache.geode.cache.CustomExpiry;
+import org.apache.geode.cache.EvictionAttributesMutator;
+import org.apache.geode.cache.ExpirationAttributes;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.asyncqueue.AsyncEventQueue;
+import org.apache.geode.cache.wan.GatewaySender;
import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
-import com.gemstone.gemfire.cache.AttributesMutator;
-import com.gemstone.gemfire.cache.CacheListener;
-import com.gemstone.gemfire.cache.CacheLoader;
-import com.gemstone.gemfire.cache.CacheWriter;
-import com.gemstone.gemfire.cache.CustomExpiry;
-import com.gemstone.gemfire.cache.EvictionAttributesMutator;
-import com.gemstone.gemfire.cache.ExpirationAttributes;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue;
-import com.gemstone.gemfire.cache.wan.GatewaySender;
-
/**
* The LookupRegionFactoryBean class is a concrete implementation of RegionLookupFactoryBean for handling
* >gfe:lookup-region/< SDG XML namespace (XSD) elements.
*
* @author John Blum
* @see org.springframework.data.gemfire.RegionLookupFactoryBean
- * @see com.gemstone.gemfire.cache.AttributesMutator
+ * @see org.apache.geode.cache.AttributesMutator
* @since 1.6.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/PartitionAttributesFactoryBean.java b/src/main/java/org/springframework/data/gemfire/PartitionAttributesFactoryBean.java
index 64bc36c1..04a9891d 100644
--- a/src/main/java/org/springframework/data/gemfire/PartitionAttributesFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/PartitionAttributesFactoryBean.java
@@ -18,18 +18,17 @@ package org.springframework.data.gemfire;
import java.util.List;
+import org.apache.geode.cache.FixedPartitionAttributes;
+import org.apache.geode.cache.PartitionAttributes;
+import org.apache.geode.cache.PartitionResolver;
+import org.apache.geode.cache.partition.PartitionListener;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
-import com.gemstone.gemfire.cache.FixedPartitionAttributes;
-import com.gemstone.gemfire.cache.PartitionAttributes;
-import com.gemstone.gemfire.cache.PartitionResolver;
-import com.gemstone.gemfire.cache.partition.PartitionListener;
-
/**
* Spring-friendly bean for creating {@link PartitionAttributes}. Eliminates the need of using
* a XML 'factory-method' tag and allows the attributes properties to be set directly.
- *
+ *
* @author Costin Leau
* @author David Turanski
* @author John Blum
@@ -37,8 +36,8 @@ import com.gemstone.gemfire.cache.partition.PartitionListener;
@SuppressWarnings({ "rawtypes", "unchecked", "unused" })
public class PartitionAttributesFactoryBean implements FactoryBean, InitializingBean {
- private final com.gemstone.gemfire.cache.PartitionAttributesFactory partitionAttributesFactory =
- new com.gemstone.gemfire.cache.PartitionAttributesFactory();
+ private final org.apache.geode.cache.PartitionAttributesFactory partitionAttributesFactory =
+ new org.apache.geode.cache.PartitionAttributesFactory();
private List listeners;
diff --git a/src/main/java/org/springframework/data/gemfire/PartitionedRegionFactoryBean.java b/src/main/java/org/springframework/data/gemfire/PartitionedRegionFactoryBean.java
index c05da736..ea919f6a 100644
--- a/src/main/java/org/springframework/data/gemfire/PartitionedRegionFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/PartitionedRegionFactoryBean.java
@@ -15,11 +15,10 @@
*/
package org.springframework.data.gemfire;
+import org.apache.geode.cache.DataPolicy;
+import org.apache.geode.cache.RegionFactory;
import org.springframework.util.Assert;
-import com.gemstone.gemfire.cache.DataPolicy;
-import com.gemstone.gemfire.cache.RegionFactory;
-
/**
* @author David Turanski
* @author John Blum
diff --git a/src/main/java/org/springframework/data/gemfire/RegionAttributesFactoryBean.java b/src/main/java/org/springframework/data/gemfire/RegionAttributesFactoryBean.java
index 76df609f..fd23bf3b 100644
--- a/src/main/java/org/springframework/data/gemfire/RegionAttributesFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/RegionAttributesFactoryBean.java
@@ -16,12 +16,11 @@
package org.springframework.data.gemfire;
+import org.apache.geode.cache.AttributesFactory;
+import org.apache.geode.cache.RegionAttributes;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
-import com.gemstone.gemfire.cache.AttributesFactory;
-import com.gemstone.gemfire.cache.RegionAttributes;
-
/**
* Spring-friendly bean for creating {@link RegionAttributes}. Eliminates the need of using a XML 'factory-method' tag.
*
@@ -29,8 +28,8 @@ import com.gemstone.gemfire.cache.RegionAttributes;
* @author John Blum
* @see org.springframework.beans.factory.FactoryBean
* @see org.springframework.beans.factory.InitializingBean
- * @see com.gemstone.gemfire.cache.AttributesFactory
- * @see com.gemstone.gemfire.cache.RegionAttributes
+ * @see org.apache.geode.cache.AttributesFactory
+ * @see org.apache.geode.cache.RegionAttributes
*/
@SuppressWarnings({ "deprecation", "unused" })
public class RegionAttributesFactoryBean extends AttributesFactory implements FactoryBean,
diff --git a/src/main/java/org/springframework/data/gemfire/RegionFactoryBean.java b/src/main/java/org/springframework/data/gemfire/RegionFactoryBean.java
index c982e342..6877df59 100644
--- a/src/main/java/org/springframework/data/gemfire/RegionFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/RegionFactoryBean.java
@@ -18,27 +18,26 @@ package org.springframework.data.gemfire;
import java.lang.reflect.Field;
-import com.gemstone.gemfire.cache.AttributesFactory;
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.CacheListener;
-import com.gemstone.gemfire.cache.CacheLoader;
-import com.gemstone.gemfire.cache.CacheWriter;
-import com.gemstone.gemfire.cache.DataPolicy;
-import com.gemstone.gemfire.cache.EvictionAction;
-import com.gemstone.gemfire.cache.GemFireCache;
-import com.gemstone.gemfire.cache.PartitionAttributes;
-import com.gemstone.gemfire.cache.PartitionAttributesFactory;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.RegionAttributes;
-import com.gemstone.gemfire.cache.RegionFactory;
-import com.gemstone.gemfire.cache.RegionShortcut;
-import com.gemstone.gemfire.cache.Scope;
-import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue;
-import com.gemstone.gemfire.cache.wan.GatewaySender;
-import com.gemstone.gemfire.internal.cache.UserSpecifiedRegionAttributes;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.geode.cache.AttributesFactory;
+import org.apache.geode.cache.Cache;
+import org.apache.geode.cache.CacheListener;
+import org.apache.geode.cache.CacheLoader;
+import org.apache.geode.cache.CacheWriter;
+import org.apache.geode.cache.DataPolicy;
+import org.apache.geode.cache.EvictionAction;
+import org.apache.geode.cache.GemFireCache;
+import org.apache.geode.cache.PartitionAttributes;
+import org.apache.geode.cache.PartitionAttributesFactory;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.RegionAttributes;
+import org.apache.geode.cache.RegionFactory;
+import org.apache.geode.cache.RegionShortcut;
+import org.apache.geode.cache.Scope;
+import org.apache.geode.cache.asyncqueue.AsyncEventQueue;
+import org.apache.geode.cache.wan.GatewaySender;
+import org.apache.geode.internal.cache.UserSpecifiedRegionAttributes;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.context.SmartLifecycle;
import org.springframework.core.io.Resource;
@@ -184,10 +183,10 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean createRegionFactory(final Cache cache) {
if (shortcut != null) {
@@ -213,10 +212,10 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean RegionFactory mergeRegionAttributes(final RegionFactory regionFactory,
@@ -332,11 +331,11 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean regionFactory) {
regionFactory.setOffHeap(Boolean.TRUE.equals(offHeap));
@@ -440,7 +439,7 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean region) {
}
@@ -453,9 +452,9 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean regionFactory, Boolean persistent, DataPolicy dataPolicy) {
if (dataPolicy != null) {
@@ -475,8 +474,8 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean regionFactory, Boolean persistent, String dataPolicy) {
if (dataPolicy != null) {
@@ -552,7 +551,7 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean region = getRegion();
@@ -626,7 +625,7 @@ public abstract class RegionFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean extends RegionLookupFactoryBean implements FactoryBean>, InitializingBean, BeanNameAware {
@@ -85,7 +84,7 @@ public abstract class RegionLookupFactoryBean implements FactoryBean implements FactoryBean implements FactoryBean implements FactoryBean parent) {
this.parent = parent;
@@ -157,7 +156,7 @@ public abstract class RegionLookupFactoryBean implements FactoryBean getParent() {
return parent;
@@ -167,7 +166,7 @@ public abstract class RegionLookupFactoryBean implements FactoryBean getRegion() {
return region;
@@ -179,7 +178,7 @@ public abstract class RegionLookupFactoryBean implements FactoryBean extends com.gemstone.gemfire.cache.AttributesFactory
+public class SubRegionFactoryBean extends org.apache.geode.cache.AttributesFactory
implements FactoryBean>, InitializingBean {
protected final Log log = LogFactory.getLog(getClass());
@@ -124,7 +123,7 @@ public class SubRegionFactoryBean extends com.gemstone.gemfire.cache.Attri
/**
* Sets the cache listeners used for the region used by this factory. Used
* only when a new region is created. Overrides the settings specified
- * through setAttributes(com.gemstone.gemfire.cache.RegionAttributes).
+ * through setAttributes(org.apache.geode.cache.RegionAttributes).
*
* @param cacheListeners the cacheListeners to set on a newly created region
*/
diff --git a/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java b/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java
index 17f80c03..4c6337f9 100644
--- a/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/SubscriptionAttributesFactoryBean.java
@@ -15,23 +15,22 @@
*/
package org.springframework.data.gemfire;
+import org.apache.geode.cache.InterestPolicy;
+import org.apache.geode.cache.SubscriptionAttributes;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.InitializingBean;
-import com.gemstone.gemfire.cache.InterestPolicy;
-import com.gemstone.gemfire.cache.SubscriptionAttributes;
-
/**
* 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
* declared their data interests.
- *
+ *
* @author Lyndon Adams
* @author John Blum
* @see org.springframework.beans.factory.FactoryBean
* @see org.springframework.beans.factory.InitializingBean
- * @see com.gemstone.gemfire.cache.InterestPolicy
- * @see com.gemstone.gemfire.cache.SubscriptionAttributes
+ * @see org.apache.geode.cache.InterestPolicy
+ * @see org.apache.geode.cache.SubscriptionAttributes
* @since 1.3.0
*/
public class SubscriptionAttributesFactoryBean implements FactoryBean, InitializingBean {
@@ -48,7 +47,7 @@ public class SubscriptionAttributesFactoryBean implements FactoryBeanThis implementation first looks for a 'bean-name' property which will be used to locate a 'template'
* bean definition. Autowiring will be performed, based on the settings defined in the Spring container.
- *
+ *
* @author Costin Leau
* @author John Blum
* @see org.springframework.beans.factory.BeanFactory
@@ -39,7 +38,7 @@ import com.gemstone.gemfire.cache.Declarable;
* @see org.springframework.beans.factory.wiring.BeanWiringInfo
* @see org.springframework.data.gemfire.DeclarableSupport
* @see org.springframework.data.gemfire.LazyWiringDeclarableSupport
- * @see com.gemstone.gemfire.cache.Declarable
+ * @see org.apache.geode.cache.Declarable
* @deprecated please use LazyWiringDeclarableSupport instead.
*/
@Deprecated
diff --git a/src/main/java/org/springframework/data/gemfire/client/ClientCacheFactoryBean.java b/src/main/java/org/springframework/data/gemfire/client/ClientCacheFactoryBean.java
index 1660c487..b84b358e 100644
--- a/src/main/java/org/springframework/data/gemfire/client/ClientCacheFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/client/ClientCacheFactoryBean.java
@@ -20,15 +20,14 @@ import java.net.InetSocketAddress;
import java.util.Map;
import java.util.Properties;
-import com.gemstone.gemfire.cache.CacheClosedException;
-import com.gemstone.gemfire.cache.GemFireCache;
-import com.gemstone.gemfire.cache.client.ClientCache;
-import com.gemstone.gemfire.cache.client.ClientCacheFactory;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.client.PoolManager;
-import com.gemstone.gemfire.distributed.DistributedSystem;
-import com.gemstone.gemfire.pdx.PdxSerializer;
-
+import org.apache.geode.cache.CacheClosedException;
+import org.apache.geode.cache.GemFireCache;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.ClientCacheFactory;
+import org.apache.geode.cache.client.Pool;
+import org.apache.geode.cache.client.PoolManager;
+import org.apache.geode.distributed.DistributedSystem;
+import org.apache.geode.pdx.PdxSerializer;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.ListableBeanFactory;
@@ -56,13 +55,13 @@ import org.springframework.util.ObjectUtils;
* @see org.springframework.data.gemfire.CacheFactoryBean
* @see org.springframework.data.gemfire.support.ConnectionEndpoint
* @see org.springframework.data.gemfire.support.ConnectionEndpointList
- * @see com.gemstone.gemfire.cache.GemFireCache
- * @see com.gemstone.gemfire.cache.client.ClientCache
- * @see com.gemstone.gemfire.cache.client.ClientCacheFactory
- * @see com.gemstone.gemfire.cache.client.Pool
- * @see com.gemstone.gemfire.cache.client.PoolManager
- * @see com.gemstone.gemfire.distributed.DistributedSystem
- * @see com.gemstone.gemfire.pdx.PdxSerializer
+ * @see org.apache.geode.cache.GemFireCache
+ * @see org.apache.geode.cache.client.ClientCache
+ * @see org.apache.geode.cache.client.ClientCacheFactory
+ * @see org.apache.geode.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolManager
+ * @see org.apache.geode.distributed.DistributedSystem
+ * @see org.apache.geode.pdx.PdxSerializer
*/
@SuppressWarnings("unused")
public class ClientCacheFactoryBean extends CacheFactoryBean implements ApplicationListener {
@@ -108,10 +107,10 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
*
* @param is Class type extension of GemFireCache.
* @return the existing GemFire ClientCache instance if available.
- * @throws com.gemstone.gemfire.cache.CacheClosedException if an existing GemFire Cache instance does not exist.
+ * @throws org.apache.geode.cache.CacheClosedException if an existing GemFire Cache instance does not exist.
* @throws java.lang.IllegalStateException if the GemFire cache instance is not a ClientCache.
- * @see com.gemstone.gemfire.cache.GemFireCache
- * @see com.gemstone.gemfire.cache.client.ClientCacheFactory#getAnyInstance()
+ * @see org.apache.geode.cache.GemFireCache
+ * @see org.apache.geode.cache.client.ClientCacheFactory#getAnyInstance()
*/
@Override
@SuppressWarnings("unchecked")
@@ -155,7 +154,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* @param gemfireProperties a Properties object containing GemFire System properties.
* @return an instance of a GemFire factory used to create a GemFire cache instance.
* @see java.util.Properties
- * @see com.gemstone.gemfire.cache.client.ClientCacheFactory
+ * @see org.apache.geode.cache.client.ClientCacheFactory
*/
@Override
protected Object createFactory(Properties gemfireProperties) {
@@ -180,7 +179,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
*
* @param clientCacheFactory the GemFire {@link ClientCacheFactory} used to configure and create
* a GemFire {@link ClientCache}.
- * @see com.gemstone.gemfire.cache.client.ClientCacheFactory
+ * @see org.apache.geode.cache.client.ClientCacheFactory
*/
ClientCacheFactory initializePdx(ClientCacheFactory clientCacheFactory) {
if (isPdxOptionsSpecified()) {
@@ -214,8 +213,8 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
*
* @param clientCacheFactory the GemFire {@link ClientCacheFactory} used to configure and create
* a GemFire {@link ClientCache}.
- * @see com.gemstone.gemfire.cache.client.ClientCacheFactory
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.ClientCacheFactory
+ * @see org.apache.geode.cache.client.Pool
*/
ClientCacheFactory initializePool(ClientCacheFactory clientCacheFactory) {
DefaultableDelegatingPoolAdapter pool = DefaultableDelegatingPoolAdapter.from(
@@ -270,8 +269,8 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* the GemFire {@link ClientCache}.
*
* @return the resolved GemFire {@link Pool}.
- * @see com.gemstone.gemfire.cache.client.PoolManager#find(String)
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolManager#find(String)
+ * @see org.apache.geode.cache.client.Pool
*/
Pool resolvePool() {
Pool localPool = getPool();
@@ -312,8 +311,8 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* @param name a String indicating the name of the GemFire {@link Pool} to find.
* @return a {@link Pool} instance with the given name registered in GemFire or null if no {@link Pool}
* with name exists.
- * @see com.gemstone.gemfire.cache.client.PoolManager#find(String)
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolManager#find(String)
+ * @see org.apache.geode.cache.client.Pool
*/
Pool findPool(String name) {
return PoolManager.find(name);
@@ -325,8 +324,8 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* @param parameterized Class type extension of {@link GemFireCache}.
* @param factory the appropriate GemFire factory used to create a cache instance.
* @return an instance of the GemFire cache.
- * @see com.gemstone.gemfire.cache.client.ClientCacheFactory#create()
- * @see com.gemstone.gemfire.cache.GemFireCache
+ * @see org.apache.geode.cache.client.ClientCacheFactory#create()
+ * @see org.apache.geode.cache.GemFireCache
*/
@Override
@SuppressWarnings("unchecked")
@@ -338,7 +337,7 @@ public class ClientCacheFactoryBean extends CacheFactoryBean implements Applicat
* Inform the GemFire cluster that this client cache is ready to receive events iff the client is non-durable.
*
* @param event the ApplicationContextEvent fired when the ApplicationContext is refreshed.
- * @see com.gemstone.gemfire.cache.client.ClientCache#readyForEvents()
+ * @see org.apache.geode.cache.client.ClientCache#readyForEvents()
* @see #getReadyForEvents()
* @see #getObject()
*/
diff --git a/src/main/java/org/springframework/data/gemfire/client/ClientRegionFactoryBean.java b/src/main/java/org/springframework/data/gemfire/client/ClientRegionFactoryBean.java
index edc3f8bf..a55d95f6 100644
--- a/src/main/java/org/springframework/data/gemfire/client/ClientRegionFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/client/ClientRegionFactoryBean.java
@@ -18,6 +18,17 @@ package org.springframework.data.gemfire.client;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.geode.cache.CacheListener;
+import org.apache.geode.cache.CacheLoader;
+import org.apache.geode.cache.CacheWriter;
+import org.apache.geode.cache.DataPolicy;
+import org.apache.geode.cache.GemFireCache;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.RegionAttributes;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.ClientRegionFactory;
+import org.apache.geode.cache.client.ClientRegionShortcut;
+import org.apache.geode.cache.client.Pool;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
@@ -31,18 +42,6 @@ import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import org.springframework.util.StringUtils;
-import com.gemstone.gemfire.cache.CacheListener;
-import com.gemstone.gemfire.cache.CacheLoader;
-import com.gemstone.gemfire.cache.CacheWriter;
-import com.gemstone.gemfire.cache.DataPolicy;
-import com.gemstone.gemfire.cache.GemFireCache;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.RegionAttributes;
-import com.gemstone.gemfire.cache.client.ClientCache;
-import com.gemstone.gemfire.cache.client.ClientRegionFactory;
-import com.gemstone.gemfire.cache.client.ClientRegionShortcut;
-import com.gemstone.gemfire.cache.client.Pool;
-
/**
* Client extension for GemFire Regions.
*
@@ -53,16 +52,16 @@ import com.gemstone.gemfire.cache.client.Pool;
* @see org.springframework.beans.factory.BeanFactoryAware
* @see org.springframework.beans.factory.DisposableBean
* @see org.springframework.data.gemfire.RegionLookupFactoryBean
- * @see com.gemstone.gemfire.cache.CacheListener
- * @see com.gemstone.gemfire.cache.CacheLoader
- * @see com.gemstone.gemfire.cache.CacheWriter
- * @see com.gemstone.gemfire.cache.DataPolicy
- * @see com.gemstone.gemfire.cache.GemFireCache
- * @see com.gemstone.gemfire.cache.Region
- * @see com.gemstone.gemfire.cache.RegionAttributes
- * @see com.gemstone.gemfire.cache.client.ClientCache
- * @see com.gemstone.gemfire.cache.client.ClientRegionFactory
- * @see com.gemstone.gemfire.cache.client.ClientRegionShortcut
+ * @see org.apache.geode.cache.CacheListener
+ * @see org.apache.geode.cache.CacheLoader
+ * @see org.apache.geode.cache.CacheWriter
+ * @see org.apache.geode.cache.DataPolicy
+ * @see org.apache.geode.cache.GemFireCache
+ * @see org.apache.geode.cache.Region
+ * @see org.apache.geode.cache.RegionAttributes
+ * @see org.apache.geode.cache.client.ClientCache
+ * @see org.apache.geode.cache.client.ClientRegionFactory
+ * @see org.apache.geode.cache.client.ClientRegionShortcut
*/
@SuppressWarnings("unused")
public class ClientRegionFactoryBean extends RegionLookupFactoryBean
@@ -183,7 +182,7 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
}
else {
// NOTE the Data Policy validation is based on the ClientRegionShortcut initialization logic
- // in com.gemstone.gemfire.internal.cache.GemFireCacheImpl.initializeClientRegionShortcuts
+ // in org.apache.geode.internal.cache.GemFireCacheImpl.initializeClientRegionShortcuts
throw new IllegalArgumentException(String.format(
"Data Policy '%1$s' is invalid for Client Regions.", this.dataPolicy));
}
@@ -239,7 +238,7 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
* configuration meta-data.
* @see #isPersistent()
* @see #isNotPersistent()
- * @see com.gemstone.gemfire.cache.client.ClientRegionShortcut
+ * @see org.apache.geode.cache.client.ClientRegionShortcut
*/
protected void assertClientRegionShortcutAndPersistentAttributeAreCompatible(final ClientRegionShortcut resolvedShortcut) {
final boolean persistentNotSpecified = (this.persistent == null);
@@ -263,7 +262,7 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
* meta-data.
* @see #isPersistent()
* @see #isNotPersistent()
- * @see com.gemstone.gemfire.cache.DataPolicy
+ * @see org.apache.geode.cache.DataPolicy
*/
protected void assertDataPolicyAndPersistentAttributeAreCompatible(final DataPolicy resolvedDataPolicy) {
if (resolvedDataPolicy.withPersistence()) {
@@ -454,7 +453,7 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
* 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.
- * @see com.gemstone.gemfire.cache.CacheLoader
+ * @see org.apache.geode.cache.CacheLoader
*/
public void setCacheLoader(CacheLoader cacheLoader) {
this.cacheLoader = cacheLoader;
@@ -464,7 +463,7 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
* 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.
- * @see com.gemstone.gemfire.cache.CacheWriter
+ * @see org.apache.geode.cache.CacheWriter
*/
public void setCacheWriter(CacheWriter cacheWriter) {
this.cacheWriter = cacheWriter;
@@ -474,7 +473,7 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
* Sets the Data Policy. Used only when a new Region is created.
*
* @param dataPolicy the client Region's Data Policy.
- * @see com.gemstone.gemfire.cache.DataPolicy
+ * @see org.apache.geode.cache.DataPolicy
*/
public void setDataPolicy(DataPolicy dataPolicy) {
this.dataPolicy = dataPolicy;
@@ -484,8 +483,8 @@ public class ClientRegionFactoryBean extends RegionLookupFactoryBean
* An alternate way to set the Data Policy, using the String name of the enumerated value.
*
* @param dataPolicyName the enumerated value String name of the Data Policy.
- * @see com.gemstone.gemfire.cache.DataPolicy
- * @see #setDataPolicy(com.gemstone.gemfire.cache.DataPolicy)
+ * @see org.apache.geode.cache.DataPolicy
+ * @see #setDataPolicy(org.apache.geode.cache.DataPolicy)
* @deprecated use setDataPolicy(:DataPolicy) instead.
*/
@Deprecated
diff --git a/src/main/java/org/springframework/data/gemfire/client/GemfireDataSourcePostProcessor.java b/src/main/java/org/springframework/data/gemfire/client/GemfireDataSourcePostProcessor.java
index 4bb4638d..ac572161 100644
--- a/src/main/java/org/springframework/data/gemfire/client/GemfireDataSourcePostProcessor.java
+++ b/src/main/java/org/springframework/data/gemfire/client/GemfireDataSourcePostProcessor.java
@@ -1,11 +1,11 @@
/*
* Copyright 2002-2013 the original author or authors.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
@@ -18,6 +18,13 @@ import java.util.List;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.geode.cache.Region;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.ClientRegionFactory;
+import org.apache.geode.cache.client.ClientRegionShortcut;
+import org.apache.geode.cache.execute.Function;
+import org.apache.geode.management.internal.cli.domain.RegionInformation;
+import org.apache.geode.management.internal.cli.functions.GetRegionsFunction;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
@@ -26,14 +33,6 @@ import org.springframework.data.gemfire.support.ListRegionsOnServerFunction;
import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
-import com.gemstone.gemfire.cache.Region;
-import com.gemstone.gemfire.cache.client.ClientCache;
-import com.gemstone.gemfire.cache.client.ClientRegionFactory;
-import com.gemstone.gemfire.cache.client.ClientRegionShortcut;
-import com.gemstone.gemfire.cache.execute.Function;
-import com.gemstone.gemfire.management.internal.cli.domain.RegionInformation;
-import com.gemstone.gemfire.management.internal.cli.functions.GetRegionsFunction;
-
/**
* 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.
@@ -44,11 +43,11 @@ import com.gemstone.gemfire.management.internal.cli.functions.GetRegionsFunction
* @see org.springframework.beans.factory.config.ConfigurableListableBeanFactory
* @see org.springframework.data.gemfire.function.execution.GemfireOnServersFunctionTemplate
* @see org.springframework.data.gemfire.support.ListRegionsOnServerFunction
- * @see com.gemstone.gemfire.cache.Region
- * @see com.gemstone.gemfire.cache.client.ClientCache
- * @see com.gemstone.gemfire.cache.client.ClientRegionFactory
- * @see com.gemstone.gemfire.cache.execute.Function
- * @see com.gemstone.gemfire.management.internal.cli.functions.GetRegionsFunction
+ * @see org.apache.geode.cache.Region
+ * @see org.apache.geode.cache.client.ClientCache
+ * @see org.apache.geode.cache.client.ClientRegionFactory
+ * @see org.apache.geode.cache.execute.Function
+ * @see org.apache.geode.management.internal.cli.functions.GetRegionsFunction
* @since 1.2.0
*/
public class GemfireDataSourcePostProcessor implements BeanFactoryPostProcessor {
@@ -63,7 +62,7 @@ public class GemfireDataSourcePostProcessor implements BeanFactoryPostProcessor
* configured in the GemFire cluster.
*
* @param clientCache the GemFire ClientCache instance.
- * @see com.gemstone.gemfire.cache.client.ClientCache
+ * @see org.apache.geode.cache.client.ClientCache
*/
public GemfireDataSourcePostProcessor(final ClientCache clientCache) {
this.clientCache = clientCache;
diff --git a/src/main/java/org/springframework/data/gemfire/client/Interest.java b/src/main/java/org/springframework/data/gemfire/client/Interest.java
index 120c1c92..885cf193 100644
--- a/src/main/java/org/springframework/data/gemfire/client/Interest.java
+++ b/src/main/java/org/springframework/data/gemfire/client/Interest.java
@@ -16,19 +16,18 @@
package org.springframework.data.gemfire.client;
+import org.apache.geode.cache.InterestResultPolicy;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.core.Constants;
import org.springframework.util.Assert;
-import com.gemstone.gemfire.cache.InterestResultPolicy;
-
/**
* The Interest class holds details for registering a client interest.
- *
+ *
* @author Costin Leau
* @author John Blum
* @see org.springframework.beans.factory.InitializingBean
- * @see com.gemstone.gemfire.cache.InterestResultPolicy
+ * @see org.apache.geode.cache.InterestResultPolicy
* @since 1.0.0
*/
@SuppressWarnings("unused")
@@ -85,7 +84,7 @@ public class Interest implements InitializingBean {
/**
* Returns the key of interest.
- *
+ *
* @return the key
*/
public K getKey() {
@@ -94,7 +93,7 @@ public class Interest implements InitializingBean {
/**
* Sets the key of interest.
- *
+ *
* @param key the key to set
*/
public void setKey(K key) {
@@ -103,7 +102,7 @@ public class Interest implements InitializingBean {
/**
* Returns the interest policy.
- *
+ *
* @return the policy
*/
public InterestResultPolicy getPolicy() {
@@ -114,7 +113,7 @@ public class Interest implements InitializingBean {
* Sets the interest policy. The argument is set as an Object
* to be able to accept both InterestResultType instances but also
* Strings (for XML configurations).
- *
+ *
* @param policy the policy to set
*/
public void setPolicy(Object policy) {
@@ -132,7 +131,7 @@ public class Interest implements InitializingBean {
/**
* Returns the interest durability.
- *
+ *
* @return the durable
*/
public boolean isDurable() {
@@ -141,7 +140,7 @@ public class Interest implements InitializingBean {
/**
* Sets the interest durability.
- *
+ *
* @param durable the durable to set
*/
public void setDurable(boolean durable) {
@@ -150,7 +149,7 @@ public class Interest implements InitializingBean {
/**
* Returns the type of values received by the listener.
- *
+ *
* @return the receiveValues
*/
public boolean isReceiveValues() {
@@ -159,7 +158,7 @@ public class Interest implements InitializingBean {
/**
* Switches between the different entities received by the listener.
- *
+ *
* @param receiveValues the receiveValues to set
*/
public void setReceiveValues(boolean receiveValues) {
diff --git a/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyConverter.java b/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyConverter.java
index 7aead724..7110cb98 100644
--- a/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyConverter.java
+++ b/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyConverter.java
@@ -16,17 +16,16 @@
package org.springframework.data.gemfire.client;
+import org.apache.geode.cache.InterestResultPolicy;
import org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport;
-import com.gemstone.gemfire.cache.InterestResultPolicy;
-
/**
* The InterestResultPolicyConverter class is a Spring Converter and JavaBeans PropertyEditor capable of converting
* a String into a GemFire InterestResultPolicyConverter.
*
* @author John Blum
* @see org.springframework.data.gemfire.support.AbstractPropertyEditorConverterSupport
- * @see com.gemstone.gemfire.cache.InterestResultPolicy
+ * @see org.apache.geode.cache.InterestResultPolicy
* @since 1.6.0
*/
public class InterestResultPolicyConverter extends AbstractPropertyEditorConverterSupport {
@@ -40,7 +39,7 @@ public class InterestResultPolicyConverter extends AbstractPropertyEditorConvert
* @see org.springframework.data.gemfire.client.InterestResultPolicyType#getInterestResultPolicy(InterestResultPolicyType)
* @see org.springframework.data.gemfire.client.InterestResultPolicyType#valueOfIgnoreCase(String)
* @see #assertConverted(String, Object, Class)
- * @see com.gemstone.gemfire.cache.InterestResultPolicy
+ * @see org.apache.geode.cache.InterestResultPolicy
*/
@Override
public InterestResultPolicy convert(final String source) {
diff --git a/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyType.java b/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyType.java
index 7708c5df..817ac8dd 100644
--- a/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyType.java
+++ b/src/main/java/org/springframework/data/gemfire/client/InterestResultPolicyType.java
@@ -16,13 +16,13 @@
package org.springframework.data.gemfire.client;
-import com.gemstone.gemfire.cache.InterestResultPolicy;
+import org.apache.geode.cache.InterestResultPolicy;
/**
* The InterestResultPolicyType enum is an enumeration of all client Register Interests (result) policy values.
*
* @author John Blum
- * @see com.gemstone.gemfire.cache.InterestResultPolicy
+ * @see org.apache.geode.cache.InterestResultPolicy
* @since 1.6.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/client/PoolAdapter.java b/src/main/java/org/springframework/data/gemfire/client/PoolAdapter.java
index bb89d72b..18368272 100644
--- a/src/main/java/org/springframework/data/gemfire/client/PoolAdapter.java
+++ b/src/main/java/org/springframework/data/gemfire/client/PoolAdapter.java
@@ -20,8 +20,8 @@ package org.springframework.data.gemfire.client;
import java.net.InetSocketAddress;
import java.util.List;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.query.QueryService;
+import org.apache.geode.cache.client.Pool;
+import org.apache.geode.cache.query.QueryService;
/**
* The PoolAdapter class is an abstract, default no-op implementation of the GemFire {@link Pool} interface
@@ -34,7 +34,7 @@ import com.gemstone.gemfire.cache.query.QueryService;
*
* @author John Blum
* @see org.springframework.data.gemfire.client.PoolFactoryBean
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.Pool
* @since 1.8.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/client/PoolFactoryBean.java b/src/main/java/org/springframework/data/gemfire/client/PoolFactoryBean.java
index 7d8dc30e..a05d9430 100644
--- a/src/main/java/org/springframework/data/gemfire/client/PoolFactoryBean.java
+++ b/src/main/java/org/springframework/data/gemfire/client/PoolFactoryBean.java
@@ -19,15 +19,14 @@ package org.springframework.data.gemfire.client;
import java.net.InetSocketAddress;
import java.util.List;
-import com.gemstone.gemfire.cache.client.ClientCache;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.client.PoolFactory;
-import com.gemstone.gemfire.cache.client.PoolManager;
-import com.gemstone.gemfire.cache.query.QueryService;
-import com.gemstone.gemfire.distributed.DistributedSystem;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.geode.cache.client.ClientCache;
+import org.apache.geode.cache.client.Pool;
+import org.apache.geode.cache.client.PoolFactory;
+import org.apache.geode.cache.client.PoolManager;
+import org.apache.geode.cache.query.QueryService;
+import org.apache.geode.distributed.DistributedSystem;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
@@ -58,9 +57,9 @@ import org.springframework.util.StringUtils;
* @see org.springframework.beans.factory.InitializingBean
* @see org.springframework.data.gemfire.support.ConnectionEndpoint
* @see org.springframework.data.gemfire.support.ConnectionEndpointList
- * @see com.gemstone.gemfire.cache.client.Pool
- * @see com.gemstone.gemfire.cache.client.PoolFactory
- * @see com.gemstone.gemfire.cache.client.PoolManager
+ * @see org.apache.geode.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolFactory
+ * @see org.apache.geode.cache.client.PoolManager
*/
@SuppressWarnings("unused")
public class PoolFactoryBean implements FactoryBean, InitializingBean, DisposableBean,
@@ -112,9 +111,9 @@ public class PoolFactoryBean implements FactoryBean, InitializingBean, Dis
* Constructs and initializes a GemFire {@link Pool}.
*
* @throws Exception if the {@link Pool} creation and initialization fails.
- * @see com.gemstone.gemfire.cache.client.Pool
- * @see com.gemstone.gemfire.cache.client.PoolFactory
- * @see com.gemstone.gemfire.cache.client.PoolManager
+ * @see org.apache.geode.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolFactory
+ * @see org.apache.geode.cache.client.PoolManager
* @see #createPoolFactory()
*/
@Override
@@ -207,11 +206,11 @@ public class PoolFactoryBean implements FactoryBean, InitializingBean, Dis
/**
* Attempts to eagerly initialize the GemFire {@link ClientCache} if not already present so that the single
- * {@link com.gemstone.gemfire.distributed.DistributedSystem} will exists, which is required to create
+ * {@link org.apache.geode.distributed.DistributedSystem} will exists, which is required to create
* a {@link Pool} instance.
*
* @see org.springframework.beans.factory.BeanFactory#getBean(Class)
- * @see com.gemstone.gemfire.cache.client.ClientCache
+ * @see org.apache.geode.cache.client.ClientCache
*/
void eagerlyInitializeClientCacheIfNotPresent() {
if (!isDistributedSystemPresent()) {
@@ -225,7 +224,7 @@ public class PoolFactoryBean implements FactoryBean, InitializingBean, Dis
* @return a boolean value indicating whether the single, GemFire DistributedSystem has been created already.
* @see org.springframework.data.gemfire.GemfireUtils#getDistributedSystem()
* @see org.springframework.data.gemfire.GemfireUtils#isConnected(DistributedSystem)
- * @see com.gemstone.gemfire.distributed.DistributedSystem
+ * @see org.apache.geode.distributed.DistributedSystem
*/
boolean isDistributedSystemPresent() {
return GemfireUtils.isConnected(GemfireUtils.getDistributedSystem());
@@ -236,8 +235,8 @@ public class PoolFactoryBean implements FactoryBean, InitializingBean, Dis
* a GemFire {@link Pool}.
*
* @return a {@link PoolFactory} implementation to create a {@link Pool}.
- * @see com.gemstone.gemfire.cache.client.PoolManager#createFactory()
- * @see com.gemstone.gemfire.cache.client.PoolFactory
+ * @see org.apache.geode.cache.client.PoolManager#createFactory()
+ * @see org.apache.geode.cache.client.PoolFactory
*/
protected PoolFactory createPoolFactory() {
return PoolManager.createFactory();
diff --git a/src/main/java/org/springframework/data/gemfire/client/support/DefaultableDelegatingPoolAdapter.java b/src/main/java/org/springframework/data/gemfire/client/support/DefaultableDelegatingPoolAdapter.java
index a189e516..b2dc1ddd 100644
--- a/src/main/java/org/springframework/data/gemfire/client/support/DefaultableDelegatingPoolAdapter.java
+++ b/src/main/java/org/springframework/data/gemfire/client/support/DefaultableDelegatingPoolAdapter.java
@@ -21,18 +21,17 @@ import java.net.InetSocketAddress;
import java.util.Collection;
import java.util.List;
+import org.apache.geode.cache.client.Pool;
+import org.apache.geode.cache.query.QueryService;
import org.springframework.data.gemfire.util.SpringUtils;
import org.springframework.util.Assert;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.query.QueryService;
-
/**
* The DefaultableDelegatingPoolAdapter class is a wrapper class around Pool allowing default configuration property
* values to be providing in the case that the Pool's setting were null.
*
* @author John Blum
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.Pool
* @since 1.8.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/client/support/DelegatingPoolAdapter.java b/src/main/java/org/springframework/data/gemfire/client/support/DelegatingPoolAdapter.java
index a60c621b..ecff636f 100644
--- a/src/main/java/org/springframework/data/gemfire/client/support/DelegatingPoolAdapter.java
+++ b/src/main/java/org/springframework/data/gemfire/client/support/DelegatingPoolAdapter.java
@@ -20,8 +20,8 @@ package org.springframework.data.gemfire.client.support;
import java.net.InetSocketAddress;
import java.util.List;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.query.QueryService;
+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
@@ -33,7 +33,7 @@ import com.gemstone.gemfire.cache.query.QueryService;
*
* @author John Blum
* @see FactoryDefaultsPoolAdapter
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.Pool
* @since 1.8.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/client/support/FactoryDefaultsPoolAdapter.java b/src/main/java/org/springframework/data/gemfire/client/support/FactoryDefaultsPoolAdapter.java
index b5abd8a0..fee33eb2 100644
--- a/src/main/java/org/springframework/data/gemfire/client/support/FactoryDefaultsPoolAdapter.java
+++ b/src/main/java/org/springframework/data/gemfire/client/support/FactoryDefaultsPoolAdapter.java
@@ -21,21 +21,20 @@ import java.net.InetSocketAddress;
import java.util.Collections;
import java.util.List;
+import org.apache.geode.cache.client.PoolFactory;
+import org.apache.geode.cache.query.QueryService;
import org.springframework.data.gemfire.GemfireUtils;
import org.springframework.data.gemfire.client.PoolAdapter;
-import com.gemstone.gemfire.cache.client.PoolFactory;
-import com.gemstone.gemfire.cache.query.QueryService;
-
/**
- * FactoryDefaultsPoolAdapter is an abstract implementation of GemFire's {@link com.gemstone.gemfire.cache.client.Pool}
+ * FactoryDefaultsPoolAdapter is an abstract implementation of GemFire's {@link org.apache.geode.cache.client.Pool}
* interface and extension of {@link PoolAdapter} providing default factory values for all configuration properties
* (e.g. freeConnectionTimeout, idleTimeout, etc).
*
* @author John Blum
* @see org.springframework.data.gemfire.client.PoolAdapter
- * @see com.gemstone.gemfire.cache.client.PoolFactory
- * @see com.gemstone.gemfire.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolFactory
+ * @see org.apache.geode.cache.client.Pool
* @since 1.8.0
*/
@SuppressWarnings("unused")
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/AbstractCacheConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/AbstractCacheConfiguration.java
index fc8f842d..135bfb68 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/AbstractCacheConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/AbstractCacheConfiguration.java
@@ -28,11 +28,10 @@ import java.util.Map;
import java.util.Properties;
import java.util.concurrent.atomic.AtomicBoolean;
-import com.gemstone.gemfire.cache.TransactionListener;
-import com.gemstone.gemfire.cache.TransactionWriter;
-import com.gemstone.gemfire.cache.util.GatewayConflictResolver;
-import com.gemstone.gemfire.pdx.PdxSerializer;
-
+import org.apache.geode.cache.TransactionListener;
+import org.apache.geode.cache.TransactionWriter;
+import org.apache.geode.cache.util.GatewayConflictResolver;
+import org.apache.geode.pdx.PdxSerializer;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanClassLoaderAware;
import org.springframework.beans.factory.BeanFactory;
@@ -67,8 +66,8 @@ import org.springframework.util.StringUtils;
* {@link org.springframework.context.annotation.Configuration} support.
*
* This class encapsulates configuration settings common to both GemFire peer
- * {@link com.gemstone.gemfire.cache.Cache caches} and
- * {@link com.gemstone.gemfire.cache.client.ClientCache client caches}.
+ * {@link org.apache.geode.cache.Cache caches} and
+ * {@link org.apache.geode.cache.client.ClientCache client caches}.
*
* @author John Blum
* @see org.springframework.beans.factory.BeanClassLoaderAware
@@ -183,7 +182,7 @@ public abstract class AbstractCacheConfiguration implements BeanClassLoaderAware
* depending on the type of configuration meta-data applied.
*
* Both 'mcast-port' and 'locators' are to set 0 and empty String respectively, which is necessary
- * for {@link com.gemstone.gemfire.cache.client.ClientCache cache client}-based applications. These values
+ * for {@link org.apache.geode.cache.client.ClientCache cache client}-based applications. These values
* can be changed for peer cache and cache server applications.
*
* Finally, GemFire's {@literal log-level} System property defaults to {@literal config}.
@@ -446,7 +445,7 @@ public abstract class AbstractCacheConfiguration implements BeanClassLoaderAware
}
/**
- * Determines whether this is a GemFire {@link com.gemstone.gemfire.cache.server.CacheServer} application,
+ * Determines whether this is a 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.
*
@@ -461,7 +460,7 @@ public abstract class AbstractCacheConfiguration implements BeanClassLoaderAware
}
/**
- * Determines whether this is a GemFire {@link com.gemstone.gemfire.cache.client.ClientCache} application,
+ * Determines whether this is a 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.
*
@@ -476,7 +475,7 @@ public abstract class AbstractCacheConfiguration implements BeanClassLoaderAware
}
/**
- * Determines whether this is a GemFire peer {@link com.gemstone.gemfire.cache.Cache} application,
+ * Determines whether this is a 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.
*
@@ -510,8 +509,8 @@ public abstract class AbstractCacheConfiguration implements BeanClassLoaderAware
}
/**
- * Determines whether this is a GemFire {@link com.gemstone.gemfire.cache.server.CacheServer} or
- * {@link com.gemstone.gemfire.cache.Cache peer cache} application, which is indicated by the presence
+ * Determines whether this is a 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.
*
@@ -529,8 +528,8 @@ public abstract class AbstractCacheConfiguration implements BeanClassLoaderAware
}
/**
- * Determine whether this Spring application is a {@link com.gemstone.gemfire.cache.server.CacheServer},
- * {@link com.gemstone.gemfire.cache.client.ClientCache} or a {@link com.gemstone.gemfire.cache.Cache} application.
+ * Determine whether this Spring application is a {@link org.apache.geode.cache.server.CacheServer},
+ * {@link org.apache.geode.cache.client.ClientCache} or a {@link org.apache.geode.cache.Cache} application.
*
* @param importMetadata {@link AnnotationMetadata} containing application configuration meta-data
* from the class type-level annotations used to configure the Spring application.
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/AddCacheServerConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/AddCacheServerConfiguration.java
index d38efa0d..1b51fa0f 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/AddCacheServerConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/AddCacheServerConfiguration.java
@@ -29,7 +29,7 @@ import org.springframework.data.gemfire.server.CacheServerFactoryBean;
/**
* The {@link AddCacheServerConfiguration} class is a Spring {@link ImportBeanDefinitionRegistrar} that registers
- * a {@link CacheServerFactoryBean} definition for the {@link com.gemstone.gemfire.cache.server.CacheServer}
+ * a {@link CacheServerFactoryBean} definition for the {@link org.apache.geode.cache.server.CacheServer}
* configuration meta-data defined in {@link EnableCacheServer}.
*
* @author John Blum
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/AddPoolConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/AddPoolConfiguration.java
index ec9477b8..3de83bea 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/AddPoolConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/AddPoolConfiguration.java
@@ -33,7 +33,7 @@ import org.springframework.util.StringUtils;
/**
* The {@link AddCacheServerConfiguration} class is a Spring {@link ImportBeanDefinitionRegistrar} that registers
- * a {@link PoolFactoryBean} definition for the {@link com.gemstone.gemfire.cache.client.Pool}
+ * a {@link PoolFactoryBean} definition for the {@link org.apache.geode.cache.client.Pool}
* configuration meta-data defined in {@link EnablePool}.
*
* @author John Blum
@@ -106,11 +106,11 @@ public class AddPoolConfiguration implements ImportBeanDefinitionRegistrar {
/**
* Uses the list of GemFire Locator and Server connection endpoint definitions and meta-data to configure
- * the GemFire client {@link com.gemstone.gemfire.cache.client.Pool} used to communicate with the servers
+ * the GemFire client {@link org.apache.geode.cache.client.Pool} used to communicate with the servers
* in the GemFire cluster.
*
* @param enablePoolAttributes {@link EnablePool} annotation containing
- * {@link com.gemstone.gemfire.cache.client.Pool} Locator/Server connection endpoint meta-data.
+ * {@link org.apache.geode.cache.client.Pool} Locator/Server connection endpoint meta-data.
* @see org.springframework.data.gemfire.config.annotation.ClientCacheApplication
* @see java.util.Map
*/
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerApplication.java b/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerApplication.java
index 36b7eea4..a82b49de 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerApplication.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerApplication.java
@@ -24,28 +24,27 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-import com.gemstone.gemfire.cache.control.ResourceManager;
-import com.gemstone.gemfire.cache.server.CacheServer;
-import com.gemstone.gemfire.cache.server.ClientSubscriptionConfig;
-
+import org.apache.geode.cache.control.ResourceManager;
+import org.apache.geode.cache.server.CacheServer;
+import org.apache.geode.cache.server.ClientSubscriptionConfig;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.data.gemfire.server.SubscriptionEvictionPolicy;
/**
* The CacheServerApplication annotation enables an embedded GemFire
- * {@link com.gemstone.gemfire.cache.server.CacheServer} instance in a Spring Data GemFire based application.
+ * {@link org.apache.geode.cache.server.CacheServer} instance in a Spring Data GemFire based application.
*
- * In addition, this also implies an embedded GemFire peer {@link com.gemstone.gemfire.cache.Cache} must exist
+ * In addition, this also implies an embedded 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
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.context.annotation.Import
* @see org.springframework.data.gemfire.config.annotation.PeerCacheConfiguration
- * @see com.gemstone.gemfire.cache.control.ResourceManager
- * @see com.gemstone.gemfire.cache.server.CacheServer
- * @see com.gemstone.gemfire.cache.server.ClientSubscriptionConfig
+ * @see org.apache.geode.cache.control.ResourceManager
+ * @see org.apache.geode.cache.server.CacheServer
+ * @see org.apache.geode.cache.server.ClientSubscriptionConfig
* @since 1.9.0
*/
@Target(ElementType.TYPE)
@@ -67,7 +66,7 @@ public @interface CacheServerApplication {
/**
* Configures the ip address or host name that this cache server will listen on.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_BIND_ADDRESS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_BIND_ADDRESS
*/
String bindAddress() default CacheServer.DEFAULT_BIND_ADDRESS;
@@ -81,7 +80,7 @@ public @interface CacheServerApplication {
/**
* Configures the percentage of heap at or above which the cache is considered in danger of becoming inoperable.
*
- * @see com.gemstone.gemfire.cache.control.ResourceManager#DEFAULT_CRITICAL_PERCENTAGE
+ * @see org.apache.geode.cache.control.ResourceManager#DEFAULT_CRITICAL_PERCENTAGE
*/
float criticalHeapPercentage() default ResourceManager.DEFAULT_CRITICAL_PERCENTAGE;
@@ -98,7 +97,7 @@ public @interface CacheServerApplication {
* Configures the percentage of heap at or above which the eviction should begin on Regions configured
* for HeapLRU eviction.
*
- * @see com.gemstone.gemfire.cache.control.ResourceManager#DEFAULT_EVICTION_PERCENTAGE
+ * @see org.apache.geode.cache.control.ResourceManager#DEFAULT_EVICTION_PERCENTAGE
*/
float evictionHeapPercentage() default ResourceManager.DEFAULT_EVICTION_PERCENTAGE;
@@ -106,14 +105,14 @@ public @interface CacheServerApplication {
* Configures the ip address or host name that server locators will tell clients that this cache server
* is listening on.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_HOSTNAME_FOR_CLIENTS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_HOSTNAME_FOR_CLIENTS
*/
String hostnameForClients() default CacheServer.DEFAULT_HOSTNAME_FOR_CLIENTS;
/**
* Configures the frequency in milliseconds to poll the load probe on this cache server.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_LOAD_POLL_INTERVAL
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_LOAD_POLL_INTERVAL
*/
long loadPollInterval() default CacheServer.DEFAULT_LOAD_POLL_INTERVAL;
@@ -147,28 +146,28 @@ public @interface CacheServerApplication {
/**
* Configures the maximum allowed client connections.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAX_CONNECTIONS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAX_CONNECTIONS
*/
int maxConnections() default CacheServer.DEFAULT_MAX_CONNECTIONS;
/**
* Configures he maximum number of messages that can be enqueued in a client-queue.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAXIMUM_MESSAGE_COUNT
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAXIMUM_MESSAGE_COUNT
*/
int maxMessageCount() default CacheServer.DEFAULT_MAXIMUM_MESSAGE_COUNT;
/**
* Configures the maximum number of threads allowed in this cache server to service client requests.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAX_THREADS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAX_THREADS
*/
int maxThreads() default CacheServer.DEFAULT_MAX_THREADS;
/**
* Configures the maximum amount of time between client pings.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS
*/
int maxTimeBetweenPings() default CacheServer.DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS;
@@ -183,7 +182,7 @@ public @interface CacheServerApplication {
/**
* Configures the time (in seconds ) after which a message in the client queue will expire.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MESSAGE_TIME_TO_LIVE
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MESSAGE_TIME_TO_LIVE
*/
int messageTimeToLive() default CacheServer.DEFAULT_MESSAGE_TIME_TO_LIVE;
@@ -197,7 +196,7 @@ public @interface CacheServerApplication {
/**
* Configures the port on which this cache server listens for clients.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_PORT
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_PORT
*/
int port() default CacheServer.DEFAULT_PORT;
@@ -211,14 +210,14 @@ public @interface CacheServerApplication {
/**
* Configures the configured buffer size of the socket connection for this CacheServer.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_SOCKET_BUFFER_SIZE
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_SOCKET_BUFFER_SIZE
*/
int socketBufferSize() default CacheServer.DEFAULT_SOCKET_BUFFER_SIZE;
/**
* Configures the capacity of the client queue.
*
- * @see com.gemstone.gemfire.cache.server.ClientSubscriptionConfig#DEFAULT_CAPACITY
+ * @see org.apache.geode.cache.server.ClientSubscriptionConfig#DEFAULT_CAPACITY
*/
int subscriptionCapacity() default ClientSubscriptionConfig.DEFAULT_CAPACITY;
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerConfiguration.java
index da72f42f..4911928c 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/CacheServerConfiguration.java
@@ -20,12 +20,11 @@ package org.springframework.data.gemfire.config.annotation;
import java.util.Map;
import java.util.Set;
-import com.gemstone.gemfire.cache.Cache;
-import com.gemstone.gemfire.cache.InterestRegistrationListener;
-import com.gemstone.gemfire.cache.server.CacheServer;
-import com.gemstone.gemfire.cache.server.ClientSubscriptionConfig;
-import com.gemstone.gemfire.cache.server.ServerLoadProbe;
-
+import org.apache.geode.cache.Cache;
+import org.apache.geode.cache.InterestRegistrationListener;
+import org.apache.geode.cache.server.CacheServer;
+import org.apache.geode.cache.server.ClientSubscriptionConfig;
+import org.apache.geode.cache.server.ServerLoadProbe;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.type.AnnotationMetadata;
@@ -42,8 +41,8 @@ import org.springframework.data.gemfire.util.SpringUtils;
* @see org.springframework.context.annotation.Bean
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.data.gemfire.config.annotation.PeerCacheConfiguration
- * @see com.gemstone.gemfire.cache.Cache
- * @see com.gemstone.gemfire.cache.server.CacheServer
+ * @see org.apache.geode.cache.Cache
+ * @see org.apache.geode.cache.server.CacheServer
* @since 1.9.0
*/
@Configuration
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheApplication.java b/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheApplication.java
index 06fcccda..eb1c4745 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheApplication.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheApplication.java
@@ -24,23 +24,22 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-import com.gemstone.gemfire.cache.client.PoolFactory;
-import com.gemstone.gemfire.cache.control.ResourceManager;
-
+import org.apache.geode.cache.client.PoolFactory;
+import org.apache.geode.cache.control.ResourceManager;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
import org.springframework.data.gemfire.GemfireUtils;
/**
* The {@link ClientCacheApplication} annotation enables a Spring Data GemFire based application to become
- * a GemFire cache client (i.e. {@link com.gemstone.gemfire.cache.client.ClientCache}).
+ * a GemFire cache client (i.e. {@link org.apache.geode.cache.client.ClientCache}).
*
* @author John Blum
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.context.annotation.Import
* @see org.springframework.data.gemfire.config.annotation.ClientCacheConfiguration
- * @see com.gemstone.gemfire.cache.client.PoolFactory
- * @see com.gemstone.gemfire.cache.control.ResourceManager
+ * @see org.apache.geode.cache.client.PoolFactory
+ * @see org.apache.geode.cache.control.ResourceManager
* @since 1.9.0
*/
@Target(ElementType.TYPE)
@@ -62,7 +61,7 @@ public @interface ClientCacheApplication {
/**
* Configures the percentage of heap at or above which the cache is considered in danger of becoming inoperable.
*
- * @see com.gemstone.gemfire.cache.control.ResourceManager#DEFAULT_CRITICAL_PERCENTAGE
+ * @see org.apache.geode.cache.control.ResourceManager#DEFAULT_CRITICAL_PERCENTAGE
*/
float criticalHeapPercentage() default ResourceManager.DEFAULT_CRITICAL_PERCENTAGE;
@@ -83,21 +82,21 @@ public @interface ClientCacheApplication {
* Configures the percentage of heap at or above which the eviction should begin on Regions configured
* for HeapLRU eviction.
*
- * @see com.gemstone.gemfire.cache.control.ResourceManager#DEFAULT_EVICTION_PERCENTAGE
+ * @see org.apache.geode.cache.control.ResourceManager#DEFAULT_EVICTION_PERCENTAGE
*/
float evictionHeapPercentage() default ResourceManager.DEFAULT_EVICTION_PERCENTAGE;
/**
* Configures the free connection timeout for this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_FREE_CONNECTION_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_FREE_CONNECTION_TIMEOUT
*/
int freeConnectionTimeout() default PoolFactory.DEFAULT_FREE_CONNECTION_TIMEOUT;
/**
* Configures the amount of time a connection can be idle before expiring the connection.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_IDLE_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_IDLE_TIMEOUT
*/
long idleTimeout() default PoolFactory.DEFAULT_IDLE_TIMEOUT;
@@ -111,12 +110,12 @@ public @interface ClientCacheApplication {
/**
* Configures the load conditioning interval for this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_LOAD_CONDITIONING_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_LOAD_CONDITIONING_INTERVAL
*/
int loadConditioningInterval() default PoolFactory.DEFAULT_LOAD_CONDITIONING_INTERVAL;
/**
- * Configures the GemFire {@link com.gemstone.gemfire.distributed.Locator}s to which
+ * Configures the GemFire {@link org.apache.geode.distributed.Locator}s to which
* this cache client will connect.
*/
Locator[] locators() default {};
@@ -131,21 +130,21 @@ public @interface ClientCacheApplication {
/**
* Configures the max number of client to server connections that the pool will create.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_MAX_CONNECTIONS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_MAX_CONNECTIONS
*/
int maxConnections() default PoolFactory.DEFAULT_MAX_CONNECTIONS;
/**
* Configures the minimum number of connections to keep available at all times.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_MIN_CONNECTIONS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_MIN_CONNECTIONS
*/
int minConnections() default PoolFactory.DEFAULT_MIN_CONNECTIONS;
/**
* If set to true then the created pool can be used by multiple users.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_MULTIUSER_AUTHENTICATION
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_MULTIUSER_AUTHENTICATION
*/
boolean multiUserAuthentication() default PoolFactory.DEFAULT_MULTIUSER_AUTHENTICATION;
@@ -159,15 +158,15 @@ public @interface ClientCacheApplication {
/**
* Configures how often to ping servers to verify that they are still alive.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_PING_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_PING_INTERVAL
*/
long pingInterval() default PoolFactory.DEFAULT_PING_INTERVAL;
/**
* By default {@code prSingleHopEnabled} is {@literal true} in which case the client is aware of the location
- * of partitions on servers hosting Regions with {@link com.gemstone.gemfire.cache.DataPolicy#PARTITION}.
+ * of partitions on servers hosting Regions with {@link org.apache.geode.cache.DataPolicy#PARTITION}.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_PR_SINGLE_HOP_ENABLED
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_PR_SINGLE_HOP_ENABLED
*/
boolean prSingleHopEnabled() default PoolFactory.DEFAULT_PR_SINGLE_HOP_ENABLED;
@@ -175,7 +174,7 @@ public @interface ClientCacheApplication {
* Configures the number of milliseconds to wait for a response from a server before timing out the operation
* and trying another server (if any are available).
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_READ_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_READ_TIMEOUT
*/
int readTimeout() default PoolFactory.DEFAULT_READ_TIMEOUT;
@@ -189,19 +188,19 @@ public @interface ClientCacheApplication {
/**
* Configures the number of times to retry a request after timeout/exception.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_RETRY_ATTEMPTS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_RETRY_ATTEMPTS
*/
int retryAttempts() default PoolFactory.DEFAULT_RETRY_ATTEMPTS;
/**
* Configures the group that all servers this pool connects to must belong to.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SERVER_GROUP
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SERVER_GROUP
*/
String serverGroup() default PoolFactory.DEFAULT_SERVER_GROUP;
/**
- * Configures the GemFire {@link com.gemstone.gemfire.cache.server.CacheServer}s to which
+ * Configures the GemFire {@link org.apache.geode.cache.server.CacheServer}s to which
* this cache client will connect.
*/
Server[] servers() default {};
@@ -209,14 +208,14 @@ public @interface ClientCacheApplication {
/**
* Configures the socket buffer size for each connection made in this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SOCKET_BUFFER_SIZE
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SOCKET_BUFFER_SIZE
*/
int socketBufferSize() default PoolFactory.DEFAULT_SOCKET_BUFFER_SIZE;
/**
* Configures how often to send client statistics to the server.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_STATISTIC_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_STATISTIC_INTERVAL
*/
int statisticInterval() default PoolFactory.DEFAULT_STATISTIC_INTERVAL;
@@ -224,14 +223,14 @@ public @interface ClientCacheApplication {
* Configures the interval in milliseconds to wait before sending acknowledgements to the cache server
* for events received from the server subscriptions.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ACK_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ACK_INTERVAL
*/
int subscriptionAckInterval() default PoolFactory.DEFAULT_SUBSCRIPTION_ACK_INTERVAL;
/**
* If set to true then the created pool will have server-to-client subscriptions enabled.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ENABLED
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ENABLED
*/
boolean subscriptionEnabled() default PoolFactory.DEFAULT_SUBSCRIPTION_ENABLED;
@@ -239,21 +238,21 @@ public @interface ClientCacheApplication {
* Configures the messageTrackingTimeout attribute which is the time-to-live period, in milliseconds,
* for subscription events the client has received from the server.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT
*/
int subscriptionMessageTrackingTimeout() default PoolFactory.DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT;
/**
* Configures the redundancy level for this pools server-to-client subscriptions.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_REDUNDANCY
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_REDUNDANCY
*/
int subscriptionRedundancy() default PoolFactory.DEFAULT_SUBSCRIPTION_REDUNDANCY;
/**
* Configures the thread local connections policy for this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_THREAD_LOCAL_CONNECTIONS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_THREAD_LOCAL_CONNECTIONS
*/
boolean threadLocalConnections() default PoolFactory.DEFAULT_THREAD_LOCAL_CONNECTIONS;
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheConfiguration.java
index 6b34a0ba..4eef2f22 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/ClientCacheConfiguration.java
@@ -34,13 +34,13 @@ import org.springframework.data.gemfire.support.ConnectionEndpointList;
/**
* Spring {@link Configuration} class used to configure, construct and initialize
- * a GemFire {@link com.gemstone.gemfire.cache.client.ClientCache} instance in a Spring application context.
+ * a GemFire {@link org.apache.geode.cache.client.ClientCache} instance in a Spring application context.
*
* @author John Blum
* @see org.springframework.context.annotation.Bean
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.data.gemfire.config.annotation.AbstractCacheConfiguration
- * @see com.gemstone.gemfire.cache.client.ClientCache
+ * @see org.apache.geode.cache.client.ClientCache
* @since 1.0.0
*/
@Configuration
@@ -143,10 +143,10 @@ public class ClientCacheConfiguration extends AbstractCacheConfiguration {
}
/**
- * Configures GemFire {@link com.gemstone.gemfire.cache.client.ClientCache} specific settings.
+ * Configures GemFire {@link org.apache.geode.cache.client.ClientCache} specific settings.
*
* @param importMetadata {@link AnnotationMetadata} containing client cache meta-data used to configure
- * the GemFire {@link com.gemstone.gemfire.cache.client.ClientCache}.
+ * the GemFire {@link org.apache.geode.cache.client.ClientCache}.
* @see org.springframework.core.type.AnnotationMetadata
*/
@Override
@@ -186,11 +186,11 @@ public class ClientCacheConfiguration extends AbstractCacheConfiguration {
/**
* Uses the list of GemFire Locator and Server connection endpoint definitions and meta-data to configure
- * the GemFire client {@link com.gemstone.gemfire.cache.client.Pool} used to communicate with the servers
+ * the GemFire client {@link org.apache.geode.cache.client.Pool} used to communicate with the servers
* in the GemFire cluster.
*
* @param clientCacheApplicationAttributes {@link ClientCacheApplication} annotation containing
- * {@link com.gemstone.gemfire.cache.client.Pool} Locator/Server connection endpoint meta-data.
+ * {@link org.apache.geode.cache.client.Pool} Locator/Server connection endpoint meta-data.
* @see org.springframework.data.gemfire.config.annotation.ClientCacheApplication
* @see java.util.Map
*/
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAuth.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAuth.java
index e486ebd2..2c7335bf 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAuth.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAuth.java
@@ -24,10 +24,9 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-import com.gemstone.gemfire.security.AccessControl;
-import com.gemstone.gemfire.security.AuthInitialize;
-import com.gemstone.gemfire.security.Authenticator;
-
+import org.apache.geode.security.AccessControl;
+import org.apache.geode.security.AuthInitialize;
+import org.apache.geode.security.Authenticator;
import org.springframework.context.annotation.Import;
/**
@@ -36,9 +35,9 @@ import org.springframework.context.annotation.Import;
*
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.AuthConfiguration
- * @see com.gemstone.gemfire.security.AccessControl
- * @see com.gemstone.gemfire.security.AuthInitialize
- * @see com.gemstone.gemfire.security.Authenticator
+ * @see org.apache.geode.security.AccessControl
+ * @see org.apache.geode.security.AuthInitialize
+ * @see org.apache.geode.security.Authenticator
* @see Authentication
* @see Authorization
* @since 1.9.0
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAutoRegionLookup.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAutoRegionLookup.java
index fac7594f..627590b2 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAutoRegionLookup.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableAutoRegionLookup.java
@@ -28,11 +28,11 @@ 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 com.gemstone.gemfire.cache.Region Regions}
+ * 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.
*
* This annotation defines the {@code enabled} attribute to allow users to dynamically change the behavior
- * of auto {@link com.gemstone.gemfire.cache.Region} lookup at application configuration time using either a SpEL
+ * of auto {@link org.apache.geode.cache.Region} lookup at application configuration time using either a SpEL
* expression or a Spring property placeholder.
*
* @author John Blum
@@ -48,11 +48,11 @@ import org.springframework.context.annotation.Import;
public @interface EnableAutoRegionLookup {
/**
- * Attribute to indicate whether auto {@link com.gemstone.gemfire.cache.Region} lookup should be enabled;
+ * Attribute to indicate whether auto {@link org.apache.geode.cache.Region} lookup should be enabled;
* Defaults to {@literal true}.
*
* This attribute accepts either a SpEL or Spring property placeholder expression so that
- * auto {@link com.gemstone.gemfire.cache.Region} lookup behavior can be determined
+ * auto {@link org.apache.geode.cache.Region} lookup behavior can be determined
* at application configuration time.
*/
String enabled() default "true";
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServer.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServer.java
index c7dc909a..00c92f6d 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServer.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServer.java
@@ -24,9 +24,8 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-import com.gemstone.gemfire.cache.server.CacheServer;
-import com.gemstone.gemfire.cache.server.ClientSubscriptionConfig;
-
+import org.apache.geode.cache.server.CacheServer;
+import org.apache.geode.cache.server.ClientSubscriptionConfig;
import org.springframework.context.annotation.Import;
import org.springframework.data.gemfire.server.SubscriptionEvictionPolicy;
@@ -43,7 +42,7 @@ import org.springframework.data.gemfire.server.SubscriptionEvictionPolicy;
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.AddCacheServerConfiguration
- * @see com.gemstone.gemfire.cache.server.CacheServer
+ * @see org.apache.geode.cache.server.CacheServer
* @since 1.9.0
*/
@Target(ElementType.TYPE)
@@ -64,7 +63,7 @@ public @interface EnableCacheServer {
/**
* Configures the ip address or host name that this cache server will listen on.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_BIND_ADDRESS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_BIND_ADDRESS
*/
String bindAddress() default CacheServer.DEFAULT_BIND_ADDRESS;
@@ -72,70 +71,70 @@ public @interface EnableCacheServer {
* Configures the ip address or host name that server locators will tell clients that this cache server
* is listening on.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_HOSTNAME_FOR_CLIENTS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_HOSTNAME_FOR_CLIENTS
*/
String hostnameForClients() default CacheServer.DEFAULT_HOSTNAME_FOR_CLIENTS;
/**
* Configures the frequency in milliseconds to poll the load probe on this cache server.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_LOAD_POLL_INTERVAL
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_LOAD_POLL_INTERVAL
*/
long loadPollInterval() default CacheServer.DEFAULT_LOAD_POLL_INTERVAL;
/**
* Configures the maximum allowed client connections.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAX_CONNECTIONS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAX_CONNECTIONS
*/
int maxConnections() default CacheServer.DEFAULT_MAX_CONNECTIONS;
/**
* Configures he maximum number of messages that can be enqueued in a client-queue.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAXIMUM_MESSAGE_COUNT
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAXIMUM_MESSAGE_COUNT
*/
int maxMessageCount() default CacheServer.DEFAULT_MAXIMUM_MESSAGE_COUNT;
/**
* Configures the maximum number of threads allowed in this cache server to service client requests.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAX_THREADS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAX_THREADS
*/
int maxThreads() default CacheServer.DEFAULT_MAX_THREADS;
/**
* Configures the maximum amount of time between client pings.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS
*/
int maxTimeBetweenPings() default CacheServer.DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS;
/**
* Configures the time (in seconds ) after which a message in the client queue will expire.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_MESSAGE_TIME_TO_LIVE
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_MESSAGE_TIME_TO_LIVE
*/
int messageTimeToLive() default CacheServer.DEFAULT_MESSAGE_TIME_TO_LIVE;
/**
* Configures the port on which this cache server listens for clients.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_PORT
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_PORT
*/
int port() default CacheServer.DEFAULT_PORT;
/**
* Configures the configured buffer size of the socket connection for this CacheServer.
*
- * @see com.gemstone.gemfire.cache.server.CacheServer#DEFAULT_SOCKET_BUFFER_SIZE
+ * @see org.apache.geode.cache.server.CacheServer#DEFAULT_SOCKET_BUFFER_SIZE
*/
int socketBufferSize() default CacheServer.DEFAULT_SOCKET_BUFFER_SIZE;
/**
* Configures the capacity of the client queue.
*
- * @see com.gemstone.gemfire.cache.server.ClientSubscriptionConfig#DEFAULT_CAPACITY
+ * @see org.apache.geode.cache.server.ClientSubscriptionConfig#DEFAULT_CAPACITY
*/
int subscriptionCapacity() default ClientSubscriptionConfig.DEFAULT_CAPACITY;
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServers.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServers.java
index 0db7d480..3da0b0ed 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServers.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableCacheServers.java
@@ -27,7 +27,7 @@ import java.lang.annotation.Target;
import org.springframework.context.annotation.Import;
/**
- * The {@link EnableCacheServers} annotation enables 1 or more GemFire {@link com.gemstone.gemfire.cache.server.CacheServer CacheServers}
+ * The {@link EnableCacheServers} annotation enables 1 or more GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers}
* to be defined and used in a GemFire peer cache application configured with Spring (Data GemFire).
*
* @author John Blum
@@ -44,7 +44,7 @@ import org.springframework.context.annotation.Import;
public @interface EnableCacheServers {
/**
- * Enables the definition of multiple GemFire {@link com.gemstone.gemfire.cache.server.CacheServer CacheServers}.
+ * Enables the definition of multiple GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers}.
*/
EnableCacheServer[] servers() default {};
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableOffHeap.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableOffHeap.java
index 021fb2da..79a24970 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnableOffHeap.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnableOffHeap.java
@@ -29,7 +29,7 @@ import org.springframework.context.annotation.Import;
/**
* The EnableOffHeap annotation marks a Spring {@link org.springframework.context.annotation.Configuration @Configuration}
* annotated class to configure and enable Apache Geode Off-Heap Memory support and data storage
- * in Geode's cache {@link com.gemstone.gemfire.cache.Region Regions}.
+ * in Geode's cache {@link org.apache.geode.cache.Region Regions}.
*
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.OffHeapConfiguration
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePdx.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePdx.java
index c48d4bc1..96f8a2c6 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePdx.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePdx.java
@@ -59,7 +59,7 @@ public @interface EnablePdx {
boolean persistent() default false;
/**
- * Configures the object preference to {@link com.gemstone.gemfire.pdx.PdxInstance} type or {@link Object}.
+ * Configures the object preference to {@link org.apache.geode.pdx.PdxInstance} type or {@link Object}.
*
* Default is {@literal false}.
*/
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePool.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePool.java
index c5ea6eb8..1294d60b 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePool.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePool.java
@@ -24,9 +24,8 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-import com.gemstone.gemfire.cache.client.Pool;
-import com.gemstone.gemfire.cache.client.PoolFactory;
-
+import org.apache.geode.cache.client.Pool;
+import org.apache.geode.cache.client.PoolFactory;
import org.springframework.context.annotation.Import;
import org.springframework.data.gemfire.GemfireUtils;
@@ -42,8 +41,8 @@ import org.springframework.data.gemfire.GemfireUtils;
*
* @author John Blum
* @see org.springframework.data.gemfire.config.annotation.AddPoolConfiguration
- * @see com.gemstone.gemfire.cache.client.Pool
- * @see com.gemstone.gemfire.cache.client.PoolFactory
+ * @see org.apache.geode.cache.client.Pool
+ * @see org.apache.geode.cache.client.PoolFactory
* @since 1.9.0
*/
@Target(ElementType.TYPE)
@@ -57,26 +56,26 @@ public @interface EnablePool {
/**
* Configures the free connection timeout for this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_FREE_CONNECTION_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_FREE_CONNECTION_TIMEOUT
*/
int freeConnectionTimeout() default PoolFactory.DEFAULT_FREE_CONNECTION_TIMEOUT;
/**
* Configures the amount of time a connection can be idle before expiring the connection.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_IDLE_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_IDLE_TIMEOUT
*/
long idleTimeout() default PoolFactory.DEFAULT_IDLE_TIMEOUT;
/**
* Configures the load conditioning interval for this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_LOAD_CONDITIONING_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_LOAD_CONDITIONING_INTERVAL
*/
int loadConditioningInterval() default PoolFactory.DEFAULT_LOAD_CONDITIONING_INTERVAL;
/**
- * Configures the GemFire {@link com.gemstone.gemfire.distributed.Locator Locators} to which
+ * Configures the GemFire {@link org.apache.geode.distributed.Locator Locators} to which
* this cache client will connect.
*/
Locator[] locators() default {};
@@ -92,21 +91,21 @@ public @interface EnablePool {
/**
* Configures the max number of client to server connections that the pool will create.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_MAX_CONNECTIONS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_MAX_CONNECTIONS
*/
int maxConnections() default PoolFactory.DEFAULT_MAX_CONNECTIONS;
/**
* Configures the minimum number of connections to keep available at all times.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_MIN_CONNECTIONS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_MIN_CONNECTIONS
*/
int minConnections() default PoolFactory.DEFAULT_MIN_CONNECTIONS;
/**
* If set to true then the created pool can be used by multiple users.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_MULTIUSER_AUTHENTICATION
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_MULTIUSER_AUTHENTICATION
*/
boolean multiUserAuthentication() default PoolFactory.DEFAULT_MULTIUSER_AUTHENTICATION;
@@ -118,15 +117,15 @@ public @interface EnablePool {
/**
* Configures how often to ping servers to verify that they are still alive.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_PING_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_PING_INTERVAL
*/
long pingInterval() default PoolFactory.DEFAULT_PING_INTERVAL;
/**
* By default {@code prSingleHopEnabled} is {@literal true} in which case the client is aware of the location
- * of partitions on servers hosting Regions with {@link com.gemstone.gemfire.cache.DataPolicy#PARTITION}.
+ * of partitions on servers hosting Regions with {@link org.apache.geode.cache.DataPolicy#PARTITION}.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_PR_SINGLE_HOP_ENABLED
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_PR_SINGLE_HOP_ENABLED
*/
boolean prSingleHopEnabled() default PoolFactory.DEFAULT_PR_SINGLE_HOP_ENABLED;
@@ -134,26 +133,26 @@ public @interface EnablePool {
* Configures the number of milliseconds to wait for a response from a server before timing out the operation
* and trying another server (if any are available).
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_READ_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_READ_TIMEOUT
*/
int readTimeout() default PoolFactory.DEFAULT_READ_TIMEOUT;
/**
* Configures the number of times to retry a request after timeout/exception.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_RETRY_ATTEMPTS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_RETRY_ATTEMPTS
*/
int retryAttempts() default PoolFactory.DEFAULT_RETRY_ATTEMPTS;
/**
* Configures the group that all servers this pool connects to must belong to.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SERVER_GROUP
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SERVER_GROUP
*/
String serverGroup() default PoolFactory.DEFAULT_SERVER_GROUP;
/**
- * Configures the GemFire {@link com.gemstone.gemfire.cache.server.CacheServer CacheServers} to which
+ * Configures the GemFire {@link org.apache.geode.cache.server.CacheServer CacheServers} to which
* this cache client will connect.
*/
Server[] servers() default {};
@@ -169,14 +168,14 @@ public @interface EnablePool {
/**
* Configures the socket buffer size for each connection made in this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SOCKET_BUFFER_SIZE
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SOCKET_BUFFER_SIZE
*/
int socketBufferSize() default PoolFactory.DEFAULT_SOCKET_BUFFER_SIZE;
/**
* Configures how often to send client statistics to the server.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_STATISTIC_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_STATISTIC_INTERVAL
*/
int statisticInterval() default PoolFactory.DEFAULT_STATISTIC_INTERVAL;
@@ -184,14 +183,14 @@ public @interface EnablePool {
* Configures the interval in milliseconds to wait before sending acknowledgements to the cache server
* for events received from the server subscriptions.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ACK_INTERVAL
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ACK_INTERVAL
*/
int subscriptionAckInterval() default PoolFactory.DEFAULT_SUBSCRIPTION_ACK_INTERVAL;
/**
* If set to true then the created pool will have server-to-client subscriptions enabled.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ENABLED
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_ENABLED
*/
boolean subscriptionEnabled() default PoolFactory.DEFAULT_SUBSCRIPTION_ENABLED;
@@ -199,21 +198,21 @@ public @interface EnablePool {
* Configures the messageTrackingTimeout attribute which is the time-to-live period, in milliseconds,
* for subscription events the client has received from the server.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT
*/
int subscriptionMessageTrackingTimeout() default PoolFactory.DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT;
/**
* Configures the redundancy level for this pools server-to-client subscriptions.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_REDUNDANCY
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_SUBSCRIPTION_REDUNDANCY
*/
int subscriptionRedundancy() default PoolFactory.DEFAULT_SUBSCRIPTION_REDUNDANCY;
/**
* Configures the thread local connections policy for this pool.
*
- * @see com.gemstone.gemfire.cache.client.PoolFactory#DEFAULT_THREAD_LOCAL_CONNECTIONS
+ * @see org.apache.geode.cache.client.PoolFactory#DEFAULT_THREAD_LOCAL_CONNECTIONS
*/
boolean threadLocalConnections() default PoolFactory.DEFAULT_THREAD_LOCAL_CONNECTIONS;
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePools.java b/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePools.java
index 04821fa8..94054d83 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePools.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/EnablePools.java
@@ -27,7 +27,7 @@ import java.lang.annotation.Target;
import org.springframework.context.annotation.Import;
/**
- * The {@link EnablePools} annotation enables 1 or more GemFire {@link com.gemstone.gemfire.cache.client.Pool Pools}
+ * 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).
*
* @author John Blum
@@ -44,7 +44,7 @@ import org.springframework.context.annotation.Import;
public @interface EnablePools {
/**
- * Enables the definition of multiple GemFire {@link com.gemstone.gemfire.cache.client.Pool Pools}.
+ * Enables the definition of multiple GemFire {@link org.apache.geode.cache.client.Pool Pools}.
*/
EnablePool[] pools() default {};
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/OffHeapConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/OffHeapConfiguration.java
index 5971b21c..886a8e28 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/OffHeapConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/OffHeapConfiguration.java
@@ -24,8 +24,7 @@ import java.util.Map;
import java.util.Properties;
import java.util.Set;
-import com.gemstone.gemfire.cache.Region;
-
+import org.apache.geode.cache.Region;
import org.springframework.beans.BeansException;
import org.springframework.beans.PropertyValue;
import org.springframework.beans.factory.BeanFactory;
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheApplication.java b/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheApplication.java
index 87e8830c..d74f01fa 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheApplication.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheApplication.java
@@ -24,20 +24,19 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
-import com.gemstone.gemfire.cache.control.ResourceManager;
-
+import org.apache.geode.cache.control.ResourceManager;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
/**
- * The {@link PeerCacheApplication} annotation enables an embedded GemFire peer {@link com.gemstone.gemfire.cache.Cache}
+ * The {@link PeerCacheApplication} annotation enables an embedded GemFire peer {@link org.apache.geode.cache.Cache}
* instance in a Spring Data GemFire based application.
*
* @author John Blum
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.context.annotation.Import
* @see org.springframework.data.gemfire.config.annotation.PeerCacheConfiguration
- * @see com.gemstone.gemfire.cache.control.ResourceManager
+ * @see org.apache.geode.cache.control.ResourceManager
* @since 1.9.0
*/
@Target({ ElementType.ANNOTATION_TYPE, ElementType.TYPE})
@@ -59,7 +58,7 @@ public @interface PeerCacheApplication {
/**
* Configures the percentage of heap at or above which the cache is considered in danger of becoming inoperable.
*
- * @see com.gemstone.gemfire.cache.control.ResourceManager#DEFAULT_CRITICAL_PERCENTAGE
+ * @see org.apache.geode.cache.control.ResourceManager#DEFAULT_CRITICAL_PERCENTAGE
*/
float criticalHeapPercentage() default ResourceManager.DEFAULT_CRITICAL_PERCENTAGE;
@@ -76,7 +75,7 @@ public @interface PeerCacheApplication {
* Configures the percentage of heap at or above which the eviction should begin on Regions configured
* for HeapLRU eviction.
*
- * @see com.gemstone.gemfire.cache.control.ResourceManager#DEFAULT_EVICTION_PERCENTAGE
+ * @see org.apache.geode.cache.control.ResourceManager#DEFAULT_EVICTION_PERCENTAGE
*/
float evictionHeapPercentage() default ResourceManager.DEFAULT_EVICTION_PERCENTAGE;
diff --git a/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheConfiguration.java b/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheConfiguration.java
index 03d01803..5e8ffc85 100644
--- a/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheConfiguration.java
+++ b/src/main/java/org/springframework/data/gemfire/config/annotation/PeerCacheConfiguration.java
@@ -26,13 +26,13 @@ import org.springframework.data.gemfire.CacheFactoryBean;
/**
* Spring {@link Configuration} class used to configure, construct and initialize
- * a GemFire peer {@link com.gemstone.gemfire.cache.Cache} instance in a Spring application context.
+ * a GemFire peer {@link org.apache.geode.cache.Cache} instance in a Spring application context.
*
* @author John Blum
* @see org.springframework.context.annotation.Bean
* @see org.springframework.context.annotation.Configuration
* @see org.springframework.data.gemfire.config.annotation.AbstractCacheConfiguration
- * @see com.gemstone.gemfire.cache.Cache
+ * @see org.apache.geode.cache.Cache
* @since 1.9.0
*/
@Configuration
@@ -77,10 +77,10 @@ public class PeerCacheConfiguration extends AbstractCacheConfiguration {
}
/**
- * Configures GemFire peer {@link com.gemstone.gemfire.cache.Cache} specific settings.
+ * Configures GemFire peer {@link org.apache.geode.cache.Cache} specific settings.
*
* @param importMetadata {@link AnnotationMetadata} containing peer cache meta-data used to configure
- * the GemFire peer {@link com.gemstone.gemfire.cache.Cache}.
+ * the GemFire peer {@link org.apache.geode.cache.Cache}.
* @see org.springframework.core.type.AnnotationMetadata
* @see #isCacheServerOrPeerCacheApplication(AnnotationMetadata)
*/
diff --git a/src/main/java/org/springframework/data/gemfire/config/support/AutoRegionLookupBeanPostProcessor.java b/src/main/java/org/springframework/data/gemfire/config/support/AutoRegionLookupBeanPostProcessor.java
index fd1ab0e0..ffad4dde 100644
--- a/src/main/java/org/springframework/data/gemfire/config/support/AutoRegionLookupBeanPostProcessor.java
+++ b/src/main/java/org/springframework/data/gemfire/config/support/AutoRegionLookupBeanPostProcessor.java
@@ -19,9 +19,8 @@ package org.springframework.data.gemfire.config.support;
import java.util.Collections;
import java.util.Set;
-import com.gemstone.gemfire.cache.GemFireCache;
-import com.gemstone.gemfire.cache.Region;
-
+import org.apache.geode.cache.GemFireCache;
+import org.apache.geode.cache.Region;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
@@ -41,8 +40,8 @@ import org.springframework.util.ObjectUtils;
* @see org.springframework.beans.factory.BeanFactory
* @see org.springframework.beans.factory.BeanFactoryAware
* @see org.springframework.beans.factory.config.BeanPostProcessor
- * @see com.gemstone.gemfire.cache.GemFireCache
- * @see com.gemstone.gemfire.cache.Region
+ * @see org.apache.geode.cache.GemFireCache
+ * @see org.apache.geode.cache.Region
* @since 1.5.0
*/
public class AutoRegionLookupBeanPostProcessor implements BeanPostProcessor, BeanFactoryAware {
diff --git a/src/main/java/org/springframework/data/gemfire/config/support/ClientRegionPoolBeanFactoryPostProcessor.java b/src/main/java/org/springframework/data/gemfire/config/support/ClientRegionPoolBeanFactoryPostProcessor.java
index 498c0469..0ff966c5 100644
--- a/src/main/java/org/springframework/data/gemfire/config/support/ClientRegionPoolBeanFactoryPostProcessor.java
+++ b/src/main/java/org/springframework/data/gemfire/config/support/ClientRegionPoolBeanFactoryPostProcessor.java
@@ -31,9 +31,9 @@ import org.springframework.data.gemfire.util.SpringUtils;
/**
* {@link ClientRegionPoolBeanFactoryPostProcessor} is a Spring {@link BeanFactoryPostProcessor} implementation
- * ensuring a proper dependency is declared between a GemFire client {@link com.gemstone.gemfire.cache.Region}
- * and the GemFire client {@link com.gemstone.gemfire.cache.client.Pool} it references and uses, providing
- * the GemFire client {@link com.gemstone.gemfire.cache.client.Pool} has been defined and configured with
+ * 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
* Spring (Data GemFire) configuration meta-data (e.g. XML).
*
* @author John Blum
diff --git a/src/main/java/org/springframework/data/gemfire/config/support/CustomEditorBeanFactoryPostProcessor.java b/src/main/java/org/springframework/data/gemfire/config/support/CustomEditorBeanFactoryPostProcessor.java
index 2cff128c..78c53e19 100644
--- a/src/main/java/org/springframework/data/gemfire/config/support/CustomEditorBeanFactoryPostProcessor.java
+++ b/src/main/java/org/springframework/data/gemfire/config/support/CustomEditorBeanFactoryPostProcessor.java
@@ -18,13 +18,12 @@ package org.springframework.data.gemfire.config.support;
import java.beans.PropertyEditorSupport;
-import com.gemstone.gemfire.cache.EvictionAction;
-import com.gemstone.gemfire.cache.ExpirationAction;
-import com.gemstone.gemfire.cache.InterestPolicy;
-import com.gemstone.gemfire.cache.InterestResultPolicy;
-import com.gemstone.gemfire.cache.Scope;
-import com.gemstone.gemfire.cache.wan.GatewaySender;
-
+import org.apache.geode.cache.EvictionAction;
+import org.apache.geode.cache.ExpirationAction;
+import org.apache.geode.cache.InterestPolicy;
+import org.apache.geode.cache.InterestResultPolicy;
+import org.apache.geode.cache.Scope;
+import org.apache.geode.cache.wan.GatewaySender;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanFactoryPostProcessor;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
diff --git a/src/main/java/org/springframework/data/gemfire/config/support/DefinedIndexesApplicationListener.java b/src/main/java/org/springframework/data/gemfire/config/support/DefinedIndexesApplicationListener.java
index 6732aad9..697b22b4 100644
--- a/src/main/java/org/springframework/data/gemfire/config/support/DefinedIndexesApplicationListener.java
+++ b/src/main/java/org/springframework/data/gemfire/config/support/DefinedIndexesApplicationListener.java
@@ -16,11 +16,10 @@
package org.springframework.data.gemfire.config.support;
-import com.gemstone.gemfire.cache.query.MultiIndexCreationException;
-import com.gemstone.gemfire.cache.query.QueryService;
-
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.geode.cache.query.MultiIndexCreationException;
+import org.apache.geode.cache.query.QueryService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
@@ -28,14 +27,14 @@ import org.springframework.data.gemfire.config.xml.GemfireConstants;
/**
* {@link DefinedIndexesApplicationListener} is a Spring {@link ApplicationListener} used to create all
- * "defined" GemFire {@link com.gemstone.gemfire.cache.query.Index Indexes} by using the {@link QueryService},
+ * "defined" GemFire {@link org.apache.geode.cache.query.Index Indexes} by using the {@link QueryService},
* {@literal defineXxxIndex(..)} methods.
*
* @author John Blum
* @see org.springframework.context.ApplicationContext
* @see org.springframework.context.ApplicationListener
* @see org.springframework.context.event.ContextRefreshedEvent
- * @see com.gemstone.gemfire.cache.query.QueryService
+ * @see org.apache.geode.cache.query.QueryService
* @since 1.7.0
*/
public class DefinedIndexesApplicationListener implements ApplicationListener {
@@ -43,13 +42,13 @@ public class DefinedIndexesApplicationListener implements ApplicationListener resultSender;
-
+
public BatchingResultSender(int batchSize, ResultSender