Spring/spring-data-gemfire
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SGF-404 - Enable Expiration settings and policies to be specified per application domain object using an @Expiration annotation and a custom, SDG-provided CustomExpiry instance.

Browse Source 
Added support for SpEL expressions in the @Expiration annotation attributes to offer even more flexibility when configuring Region Entry values, application domain object Expiration policies and settings.
This commit is contained in:
John Blum
2015-07-29 16:02:43 -07:00
parent 419eb8d879
commit 6e73f52025
7 changed files with 171 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

84
src/main/java/org/springframework/data/gemfire/support/AnnotationBasedExpiration.java
View File

@@ -17,9 +17,20 @@
package org.springframework.data.gemfire.support;
import java.lang.annotation.Annotation;
import java.util.concurrent.atomic.AtomicReference;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
import org.springframework.context.expression.BeanFactoryResolver;
import org.springframework.core.annotation.AnnotationUtils;
import org.springframework.data.gemfire.ExpirationActionConverter;
import org.springframework.data.gemfire.ExpirationActionType;
import org.springframework.expression.Expression;
import org.springframework.expression.ExpressionParser;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import com.gemstone.gemfire.cache.CustomExpiry;
@@ -34,15 +45,22 @@ import com.gemstone.gemfire.cache.Region;
* Annotations.
*
* @author John Blum
* @see org.springframework.beans.factory.BeanFactory
* @see org.springframework.beans.factory.BeanFactoryAware
* @see org.springframework.data.gemfire.ExpirationActionType
* @see org.springframework.data.gemfire.support.Expiration
* @see org.springframework.data.gemfire.support.IdleTimeoutExpiration
* @see org.springframework.data.gemfire.support.TimeToLiveExpiration
* @see com.gemstone.gemfire.cache.CustomExpiry
* @see com.gemstone.gemfire.cache.ExpirationAction
* @see com.gemstone.gemfire.cache.ExpirationAttributes
* @see com.gemstone.gemfire.cache.Region
* @since 1.7.0
*/
@SuppressWarnings("unused")
public class AnnotationBasedExpiration<K, V> implements CustomExpiry<K, V> {
public class AnnotationBasedExpiration<K, V> implements BeanFactoryAware, CustomExpiry<K, V> {
private static final AtomicReference<BeanFactory> beanFactory = new AtomicReference<BeanFactory>(null);
//private ExpirationAttributes defaultExpirationAttributes = ExpirationAttributes.DEFAULT;
private ExpirationAttributes defaultExpirationAttributes;
@@ -51,6 +69,7 @@ public class AnnotationBasedExpiration<K, V> implements CustomExpiry<K, V> {
* Constructs a new instance of the AnnotationBasedExpiration class with no default expiration policy.
*/
public AnnotationBasedExpiration() {
this(null);
}
/**
@@ -136,6 +155,17 @@ public class AnnotationBasedExpiration<K, V> implements CustomExpiry<K, V> {
};
}
@Override
public void setBeanFactory(final BeanFactory beanFactory) throws BeansException {
AnnotationBasedExpiration.beanFactory.set(beanFactory);
}
protected BeanFactory getBeanFactory() {
BeanFactory localBeanFactory = beanFactory.get();
Assert.state(localBeanFactory != null, "beanFactory was not properly initialized");
return localBeanFactory;
}
/**
* Sets the expiration policy to use by default when no application domain object specific expiration meta-data
* has been specified.
@@ -306,13 +336,15 @@ public class AnnotationBasedExpiration<K, V> implements CustomExpiry<K, V> {
*/
protected static class ExpirationMetaData {
private static final ExpirationActionConverter EXPIRATION_ACTION_CONVERTER = new ExpirationActionConverter();
private final int timeout;
private final ExpirationActionType expirationAction;
private final ExpirationActionType action;
protected ExpirationMetaData(final int timeout, final ExpirationActionType expirationAction) {
protected ExpirationMetaData(int timeout, ExpirationActionType action) {
this.timeout = timeout;
this.expirationAction = expirationAction;
this.action = action;
}
protected static ExpirationMetaData from(ExpirationAttributes expirationAttributes) {
@@ -321,23 +353,59 @@ public class AnnotationBasedExpiration<K, V> implements CustomExpiry<K, V> {
}
protected static ExpirationMetaData from(Expiration expiration) {
return new ExpirationMetaData(expiration.timeout(), expiration.action());
return new ExpirationMetaData(parseTimeout(expiration.timeout()), parseAction(expiration.action()));
}
protected static ExpirationMetaData from(IdleTimeoutExpiration expiration) {
return new ExpirationMetaData(expiration.timeout(), expiration.action());
return new ExpirationMetaData(parseTimeout(expiration.timeout()), parseAction(expiration.action()));
}
protected static ExpirationMetaData from(TimeToLiveExpiration expiration) {
return new ExpirationMetaData(expiration.timeout(), expiration.action());
return new ExpirationMetaData(parseTimeout(expiration.timeout()), parseAction(expiration.action()));
}
public ExpirationAttributes toExpirationAttributes() {
return new ExpirationAttributes(timeout(), expirationAction());
}
protected static int parseTimeout(String timeout) {
try {
return Integer.parseInt(timeout);
}
catch (NumberFormatException ignore) {
StandardEvaluationContext evaluationContext = new StandardEvaluationContext();
evaluationContext.setBeanResolver(new BeanFactoryResolver(beanFactory.get()));
return new SpelExpressionParser().parseExpression(timeout).getValue(evaluationContext, Integer.TYPE);
}
}
protected static ExpirationActionType parseAction(String action) {
try {
return ExpirationActionType.valueOf(EXPIRATION_ACTION_CONVERTER.convert(action));
}
catch (RuntimeException e) {
StandardEvaluationContext evaluationContext = new StandardEvaluationContext();
evaluationContext.setBeanResolver(new BeanFactoryResolver(beanFactory.get()));
ExpressionParser parser = new SpelExpressionParser();
Expression expression = parser.parseExpression(action);
Class<?> valueType = expression.getValueType(evaluationContext);
if (String.class.equals(valueType)) {
return ExpirationActionType.valueOfIgnoreCase(expression.getValue(evaluationContext, String.class));
}
else if (ExpirationAction.class.equals(valueType)) {
return ExpirationActionType.valueOf(expression.getValue(evaluationContext, ExpirationAction.class));
}
else {
return expression.getValue(evaluationContext, ExpirationActionType.class);
}
}
}
public ExpirationActionType action() {
return expirationAction;
return action;
}
public ExpirationAction expirationAction() {

6
src/main/java/org/springframework/data/gemfire/support/Expiration.java
View File

@@ -23,8 +23,6 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.data.gemfire.ExpirationActionType;
/**
* Expiration is an enumerated type encapsulating custom expiration settings for application domain objects
* to express their general expiration policy.
@@ -39,8 +37,8 @@ import org.springframework.data.gemfire.ExpirationActionType;
@Target({ ElementType.ANNOTATION_TYPE, ElementType.TYPE })
public @interface Expiration {
ExpirationActionType action() default ExpirationActionType.INVALIDATE;
String action() default "INVALIDATE";
int timeout() default 0;
String timeout() default "0";
}

6
src/main/java/org/springframework/data/gemfire/support/IdleTimeoutExpiration.java
View File

@@ -23,8 +23,6 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.data.gemfire.ExpirationActionType;
/**
* IdleTimeoutExpiration is an enumerated type encapsulating custom expiration settings for application domain objects
* to express their idle-timeout (TTI) expiration policy.
@@ -41,8 +39,8 @@ import org.springframework.data.gemfire.ExpirationActionType;
@SuppressWarnings("unused")
public @interface IdleTimeoutExpiration {
ExpirationActionType action() default ExpirationActionType.INVALIDATE;
String action() default "INVALIDATE";
int timeout() default 0;
String timeout() default "0";
}

6
src/main/java/org/springframework/data/gemfire/support/TimeToLiveExpiration.java
View File

@@ -23,8 +23,6 @@ import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
import org.springframework.data.gemfire.ExpirationActionType;
/**
* TimeToLiveExpiration is an enumerated type encapsulating custom expiration settings for application domain objects
* to express their time-to-live (TTL) expiration policy.
@@ -41,8 +39,8 @@ import org.springframework.data.gemfire.ExpirationActionType;
@SuppressWarnings("unused")
public @interface TimeToLiveExpiration {
ExpirationActionType action() default ExpirationActionType.INVALIDATE;
String action() default "INVALIDATE";
int timeout() default 0;
String timeout() default "0";
}