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

Provide ability to reset Cluster-Aware Configuration Condition state.

Browse Source
This commit is contained in:
John Blum
2019-08-30 17:41:21 -07:00
parent c1d7424de1
commit a8e29f7065
3 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-geode/src/test/java/org/springframework/geode/config/annotation/ClusterAvailableConfigurationIntegrationTests.java
View File

@@ -85,6 +85,9 @@ public class ClusterAvailableConfigurationIntegrationTests extends ForkingClient
@BeforeClass
public static void runGemFireServer() throws IOException {
ClusterAwareConfiguration.ClusterAwareCondition.reset();
startGemFireServer(GeodeServerApplication.class);
}

15
spring-geode/src/test/java/org/springframework/geode/config/annotation/ClusterNotAvailableConfigurationIntegrationTests.java
View File

@@ -25,6 +25,7 @@ import org.apache.geode.cache.Region;
import org.apache.geode.cache.client.ClientRegionShortcut;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -61,12 +62,20 @@ import example.app.crm.service.CustomerService;
* @since 1.2.0
*/
@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
@SpringBootTest(
classes = ClusterNotAvailableConfigurationIntegrationTests.GeodeClientApplication.class,
webEnvironment = SpringBootTest.WebEnvironment.NONE
)
@SuppressWarnings("unused")
public class ClusterNotAvailableConfigurationIntegrationTests extends IntegrationTestsSupport {
private static final String LOG_LEVEL = "error";
@BeforeClass
public static void setup() {
ClusterAwareConfiguration.ClusterAwareCondition.reset();
}
@Resource(name = "Customers")
private Region<Long, Customer> customers;
@@ -77,7 +86,7 @@ public class ClusterNotAvailableConfigurationIntegrationTests extends Integratio
private Region<Object, Object> example;
@Before
public void setup() {
public void assertRegionConfiguration() {
assertRegion(this.example, "Example", DataPolicy.NORMAL, null);
assertRegion(this.customers, "Customers", DataPolicy.NORMAL, null);
@@ -121,7 +130,7 @@ public class ClusterNotAvailableConfigurationIntegrationTests extends Integratio
@EnableClusterAware
@EnableCachingDefinedRegions
@EnableEntityDefinedRegions(basePackageClasses = Customer.class)
@ClientCacheApplication(name = "ClusterAvailableConfigurationIntegrationTests", logLevel = LOG_LEVEL)
@ClientCacheApplication(name = "ClusterNotAvailableConfigurationIntegrationTests", logLevel = LOG_LEVEL)
static class GeodeClientApplication {
@Bean("Example")