diff --git a/.gitignore b/.gitignore index ed33517e7f..742cbcc685 100644 --- a/.gitignore +++ b/.gitignore @@ -22,4 +22,4 @@ si.java.hsp spring-integration-jms/activemq-data/ spring-integration-samples/loanshark/application.log* target -vf.gf.dmn-*.cfg +vf.gf.dmn-* \ No newline at end of file diff --git a/spring-integration-gemfire/pom.xml b/spring-integration-gemfire/pom.xml index 794ede60f1..e016a91269 100644 --- a/spring-integration-gemfire/pom.xml +++ b/spring-integration-gemfire/pom.xml @@ -92,16 +92,10 @@ - - org.springframework.integration - spring-integration-test - 2.1.0.BUILD-SNAPSHOT - test - org.springframework.data.gemfire spring-gemfire - 1.1.0.M2 + 1.1.0.M3 compile @@ -118,6 +112,18 @@ + + org.springframework.integration + spring-integration-test + 2.1.0.BUILD-SNAPSHOT + test + + + org.springframework.integration + spring-integration-core + 2.1.0.BUILD-SNAPSHOT + compile + org.springframework spring-test @@ -144,9 +150,9 @@ org.springframework.integration - spring-integration-core + spring-integration-stream 2.1.0.BUILD-SNAPSHOT - compile + test org.easymock @@ -160,12 +166,6 @@ 2.3 test - - org.springframework.integration - spring-integration-stream - 2.1.0.BUILD-SNAPSHOT - test - org.springframework spring-context diff --git a/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/store/GemfireMessageStore.java b/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/store/GemfireMessageStore.java index c3527de24b..9bdc9a7e2e 100644 --- a/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/store/GemfireMessageStore.java +++ b/spring-integration-gemfire/src/main/java/org/springframework/integration/gemfire/store/GemfireMessageStore.java @@ -21,6 +21,7 @@ import java.util.Collection; import java.util.List; import org.springframework.beans.factory.InitializingBean; +import org.springframework.data.gemfire.RegionAttributesFactoryBean; import org.springframework.data.gemfire.RegionFactoryBean; import org.springframework.integration.store.AbstractKeyValueMessageStore; import org.springframework.integration.store.MessageGroupStore; @@ -30,7 +31,6 @@ import org.springframework.util.PatternMatchUtils; import com.gemstone.gemfire.cache.Cache; import com.gemstone.gemfire.cache.Region; -import com.gemstone.gemfire.internal.cache.xmlcache.RegionAttributesCreation; /** * Gemfire implementation of the key/value style {@link MessageStore} and {@link MessageGroupStore} @@ -39,23 +39,43 @@ import com.gemstone.gemfire.internal.cache.xmlcache.RegionAttributesCreation; * @author Oleg Zhurakousky * @since 2.1 */ -public class GemfireMessageStore extends AbstractKeyValueMessageStore implements InitializingBean{ +public class GemfireMessageStore extends AbstractKeyValueMessageStore implements InitializingBean { private volatile Region messageStoreRegion; - + private final Cache cache; - + private volatile boolean ignoreJta = true; + public GemfireMessageStore(Cache cache) { Assert.notNull(cache, "'cache' must not be null"); this.cache = cache; } - + + public void setIgnoreJta(boolean ignoreJta) { this.ignoreJta = ignoreJta; } + @SuppressWarnings("unchecked") + public void afterPropertiesSet() { + try { + RegionAttributesFactoryBean attributesFactoryBean = new RegionAttributesFactoryBean(); + attributesFactoryBean.setIgnoreJTA(this.ignoreJta); + attributesFactoryBean.afterPropertiesSet(); + RegionFactoryBean messageRegionFactoryBean = new RegionFactoryBean(); + messageRegionFactoryBean.setBeanName("messageStoreRegion"); + messageRegionFactoryBean.setAttributes(attributesFactoryBean.getObject()); + messageRegionFactoryBean.setCache(cache); + messageRegionFactoryBean.afterPropertiesSet(); + this.messageStoreRegion = messageRegionFactoryBean.getObject(); + } + catch (Exception e) { + throw new IllegalArgumentException("Failed to initialize Gemfire Region", e); + } + } + @Override protected Object doRetrieve(Object id) { Assert.notNull(id, "'id' must not be null"); @@ -89,20 +109,4 @@ public class GemfireMessageStore extends AbstractKeyValueMessageStore implements return keyList; } - @SuppressWarnings("unchecked") - public void afterPropertiesSet() throws Exception { - try { - RegionAttributesCreation attributes = new RegionAttributesCreation(); - attributes.setIgnoreJTA(ignoreJta); - RegionFactoryBean messageRegionFactoryBean = new RegionFactoryBean(); - messageRegionFactoryBean.setBeanName("messageStoreRegion"); - messageRegionFactoryBean.setAttributes(attributes); - messageRegionFactoryBean.setCache(cache); - messageRegionFactoryBean.afterPropertiesSet(); - - this.messageStoreRegion = messageRegionFactoryBean.getObject(); - } catch (Exception e) { - throw new IllegalArgumentException("Failed to initialize Gemfire Region", e); - } - } }