From 25733e6e1f4db5581a49f54b3744d37176e71f47 Mon Sep 17 00:00:00 2001 From: John Blum Date: Mon, 27 Jun 2022 09:35:52 -0700 Subject: [PATCH] Refactor the EnableClusterDefinedRegionsIntegrationTests to declare a client-only Region. --- ...ClusterDefinedRegionsIntegrationTests.java | 27 +++++++++++++++++++ 1 file changed, 27 insertions(+) diff --git a/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableClusterDefinedRegionsIntegrationTests.java b/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableClusterDefinedRegionsIntegrationTests.java index 76519e0c..844671ae 100644 --- a/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableClusterDefinedRegionsIntegrationTests.java +++ b/spring-data-geode/src/test/java/org/springframework/data/gemfire/config/annotation/EnableClusterDefinedRegionsIntegrationTests.java @@ -28,6 +28,7 @@ import org.apache.geode.cache.DataPolicy; import org.apache.geode.cache.GemFireCache; import org.apache.geode.cache.Region; import org.apache.geode.cache.client.ClientCache; +import org.apache.geode.cache.client.ClientRegionShortcut; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; @@ -37,6 +38,7 @@ import org.springframework.context.support.PropertySourcesPlaceholderConfigurer; import org.springframework.data.gemfire.LocalRegionFactoryBean; import org.springframework.data.gemfire.PartitionedRegionFactoryBean; import org.springframework.data.gemfire.ReplicatedRegionFactoryBean; +import org.springframework.data.gemfire.client.ClientRegionFactoryBean; import org.springframework.data.gemfire.support.ConnectionEndpoint; import org.springframework.data.gemfire.tests.integration.ForkingClientServerIntegrationTestsSupport; import org.springframework.data.gemfire.util.CacheUtils; @@ -72,6 +74,10 @@ public class EnableClusterDefinedRegionsIntegrationTests extends ForkingClientSe @Autowired private ClientCache cache; + @Autowired + @Qualifier("Example") + private Region exampleRegion; + @Autowired @Qualifier("LocalRegion") private Region localClientProxyRegion; @@ -100,6 +106,16 @@ public class EnableClusterDefinedRegionsIntegrationTests extends ForkingClientSe assertThat(CacheUtils.isClient(this.cache)); } + @Test + public void exampleRegionIsClientOnly() { + + assertThat(this.exampleRegion).isNotNull(); + assertThat(this.exampleRegion.getName()).isEqualTo("Example"); + assertThat(this.exampleRegion.getFullPath()).isEqualTo(RegionUtils.toRegionPath("Example")); + assertThat(this.exampleRegion.getAttributes()).isNotNull(); + assertThat(this.exampleRegion.getAttributes().getDataPolicy()).isEqualTo(DataPolicy.NORMAL); + } + @Test public void clusterRegionsExistOnClient() { @@ -125,6 +141,17 @@ public class EnableClusterDefinedRegionsIntegrationTests extends ForkingClientSe Collections.singletonList(new ConnectionEndpoint("localhost", port))); } + @Bean("Example") + ClientRegionFactoryBean exampleRegion(ClientCache clientCache) { + + ClientRegionFactoryBean exampleRegion = new ClientRegionFactoryBean<>(); + + exampleRegion.setCache(clientCache); + exampleRegion.setShortcut(ClientRegionShortcut.LOCAL); + + return exampleRegion; + } + @Bean("TestBean") Object testBean(@Qualifier("LocalRegion") Region localRegion) { return "TEST";