SGF-71

+ add support for region interest receive-values property

src/main/java/org/springframework/data/gemfire/IndexFactoryBean.java

@@ -45,6 +45,7 @@ public class IndexFactoryBean implements InitializingBean, BeanNameAware, Factor
 	private String beanName;
 	private String name, expression, from, imports;
 	private IndexType type = IndexType.FUNCTIONAL;
+	private boolean override = true;
 
 	public void afterPropertiesSet() throws Exception {
 		if (queryService == null) {
@@ -72,8 +73,23 @@ public class IndexFactoryBean implements InitializingBean, BeanNameAware, Factor
 
 	private Index createIndex(QueryService queryService, String indexName) throws Exception {
 		Collection<Index> indexes = queryService.getIndexes();
+
+		Index old = null;
+
 		for (Index index : indexes) {
 			if (indexName.equals(index.getName())) {
+				if (!override) {
+					return index;
+				}
+				old = index;
+				break;
+			}
+		}
+
+		if (old != null) {
+			// compare indices
+			if (from.equals(old.getFromClause()) && expression.equals(old.getIndexedExpression())
+					&& type.equals(old.getType())) {
 				return index;
 			}
 		}
@@ -167,4 +183,11 @@ public class IndexFactoryBean implements InitializingBean, BeanNameAware, Factor
 	public void setType(IndexType type) {
 		this.type = type;
 	}
+
+	/**
+	 * @param override the override to set
+	 */
+	public void setOverride(boolean override) {
+		this.override = override;
+	}
 }

src/main/java/org/springframework/data/gemfire/client/ClientRegionFactoryBean.java

@@ -153,10 +153,12 @@ public class ClientRegionFactoryBean<K, V> extends RegionLookupFactoryBean<K, V>
 			for (Interest<K> interest : interests) {
 				if (interest instanceof RegexInterest) {
 					// do the cast since it's safe
-					region.registerInterestRegex((String) interest.getKey(), interest.getPolicy(), interest.isDurable());
+					region.registerInterestRegex((String) interest.getKey(), interest.getPolicy(),
+							interest.isDurable(), interest.isReceiveValues());
 				}
 				else {
-					region.registerInterest(interest.getKey(), interest.getPolicy(), interest.isDurable());
+					region.registerInterest(interest.getKey(), interest.getPolicy(), interest.isDurable(),
+							interest.isReceiveValues());
 				}
 			}
 		}

src/main/java/org/springframework/data/gemfire/client/Interest.java

@@ -35,6 +35,7 @@ public class Interest<K> implements InitializingBean {
 	private K key;
 	private InterestResultPolicy policy = InterestResultPolicy.DEFAULT;
 	private boolean durable = false;
+	private boolean receiveValues = true;
 
 	public Interest() {
 	}
@@ -52,20 +53,25 @@ public class Interest<K> implements InitializingBean {
 	}
 
 	public Interest(K key, String policy, boolean durable) {
-		this.key = key;
-		this.policy = (InterestResultPolicy) constants.asObject(policy);
-		this.durable = durable;
-		afterPropertiesSet();
+		this(key, policy, false, true);
+	}
+
+	public Interest(K key, String policy, boolean durable, boolean receiveValues) {
+		this(key, (InterestResultPolicy) constants.asObject(policy), durable, receiveValues);
 	}
 
 	public Interest(K key, InterestResultPolicy policy, boolean durable) {
+		this(key, policy, durable, true);
+	}
+
+	public Interest(K key, InterestResultPolicy policy, boolean durable, boolean receiveValues) {
 		this.key = key;
 		this.policy = policy;
 		this.durable = durable;
+		this.receiveValues = receiveValues;
 		afterPropertiesSet();
 	}
 
-
 	public void afterPropertiesSet() {
 		Assert.notNull(key, "a non-null key is required");
 	}
@@ -135,4 +141,22 @@ public class Interest<K> implements InitializingBean {
 	public void setDurable(boolean durable) {
 		this.durable = durable;
 	}
+
+	/**
+	 * Returns the type of values received by the listener.
+	 * 
+	 * @return the receiveValues
+	 */
+	protected boolean isReceiveValues() {
+		return receiveValues;
+	}
+
+	/**
+	 * Switches between the different entities received by the listener.
+	 * 
+	 * @param receiveValues the receiveValues to set
+	 */
+	public void setReceiveValues(boolean receiveValues) {
+		this.receiveValues = receiveValues;
+	}
 }

src/main/java/org/springframework/data/gemfire/config/ClientRegionParser.java

@@ -145,5 +145,6 @@ class ClientRegionParser extends AliasReplacingBeanDefinitionParser {
 	private void parseCommonInterestAttr(Element element, BeanDefinitionBuilder builder) {
 		ParsingUtils.setPropertyValue(element, builder, "durable", "durable");
 		ParsingUtils.setPropertyValue(element, builder, "result-policy", "policy");
+		ParsingUtils.setPropertyValue(element, builder, "receive-values", "receiveValues");
 	}
 }