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

SGF-15

Browse Source 
+ allow clients to have no interests registered
This commit is contained in:
costin
2010-08-31 14:46:10 +03:00
parent 8207823c30
commit 50252e228f
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/org/springframework/data/gemfire/ClientRegionFactoryBean.java
View File

@@ -16,7 +16,7 @@
package org.springframework.data.gemfire;
import org.springframework.util.Assert;
import org.springframework.util.ObjectUtils;
import com.gemstone.gemfire.cache.Region;
@@ -31,15 +31,15 @@ public class ClientRegionFactoryBean<K, V> extends RegionFactoryBean<K, V> {
@Override
protected void postProcess(Region<K, V> region) {
Assert.notEmpty(interests);
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());
}
else {
region.registerInterest(interest.getKey(), interest.getPolicy(), interest.isDurable());
if (!ObjectUtils.isEmpty(interests)) {
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());
}
else {
region.registerInterest(interest.getKey(), interest.getPolicy(), interest.isDurable());
}
}
}
}
@@ -49,7 +49,7 @@ public class ClientRegionFactoryBean<K, V> extends RegionFactoryBean<K, V> {
Region<K, V> region = getObject();
// unregister interests
try {
if (region != null) {
if (region != null && !ObjectUtils.isEmpty(interests)) {
for (Interest<K> interest : interests) {
if (interest instanceof RegexInterest) {
region.unregisterInterestRegex((String) interest.getKey());