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

Add LocatorConfigurer to LocatorApplication configuration class to disable Apache Geode Cluster Configuration.

Browse Source 
Add Before and After cleanup() method to remove any Locator runtime files and directories.
This commit is contained in:
John Blum
2019-09-03 12:50:04 -07:00
parent ea3889174a
commit 263206a3c0
1 changed files with 21 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
spring-geode/src/test/java/org/springframework/geode/config/annotation/LocatorsConfigurationIntegrationTests.java
View File

@@ -25,13 +25,18 @@ import org.apache.geode.cache.Cache;
import org.apache.geode.cache.client.ClientCache;
import org.apache.geode.distributed.Locator;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.springframework.context.annotation.Bean;
import org.springframework.data.gemfire.config.annotation.ClientCacheApplication;
import org.springframework.data.gemfire.config.annotation.LocatorApplication;
import org.springframework.data.gemfire.config.annotation.LocatorConfigurer;
import org.springframework.data.gemfire.config.annotation.PeerCacheApplication;
import org.springframework.data.gemfire.tests.integration.SpringApplicationContextIntegrationTestsSupport;
import org.springframework.data.gemfire.tests.mock.annotation.EnableGemFireMockObjects;
import org.springframework.data.gemfire.tests.util.FileSystemUtils;
/**
* Integration tests for {@link UseLocators} and {@link LocatorsConfiguration}.
@@ -53,6 +58,13 @@ import org.springframework.data.gemfire.tests.mock.annotation.EnableGemFireMockO
@SuppressWarnings("unused")
public class LocatorsConfigurationIntegrationTests extends SpringApplicationContextIntegrationTestsSupport {
@Before @After
public void cleanup() {
FileSystemUtils.deleteRecursive(FileSystemUtils.WORKING_DIRECTORY, file ->
file != null && (file.getName().contains("locator") || file.getName().contains("ConfigDiskDir")));
}
@Test
public void clientCacheLocatorPropertiesAreNotPresent() {
@@ -109,7 +121,15 @@ public class LocatorsConfigurationIntegrationTests extends SpringApplicationCont
@EnableGemFireMockObjects
@LocatorApplication(logLevel = "error")
@UseLocators(locators = "skullbox[11235]", remoteLocators = "remotehost[12480]")
static class LocatorTestConfiguration { }
static class LocatorTestConfiguration {
@Bean
LocatorConfigurer locatorUseClusterConfigurationConfigurer() {
return (beanName, locatorFactoryBean) -> locatorFactoryBean.getGemFireProperties()
.setProperty("use-cluster-configuration", Boolean.FALSE.toString());
}
}
@EnableGemFireMockObjects
@PeerCacheApplication(logLevel = "error")