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

DATAGEODE-76 - When SDG Annotation config is used to configure and bootstrap an Apache Geode server, automatically register the Administrative Functions.

Browse Source
This commit is contained in:
John Blum
2017-12-15 19:53:37 -08:00
parent 2daf115aa7
commit be32170cb6
3 changed files with 67 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/test/java/org/springframework/data/gemfire/config/annotation/EnableClusterConfigurationIntegrationTests.java
View File

@@ -42,11 +42,7 @@ import org.springframework.data.gemfire.PartitionedRegionFactoryBean;
import org.springframework.data.gemfire.ReplicatedRegionFactoryBean;
import org.springframework.data.gemfire.client.ClientRegionFactoryBean;
import org.springframework.data.gemfire.config.admin.GemfireAdminOperations;
import org.springframework.data.gemfire.config.admin.functions.CreateIndexFunction;
import org.springframework.data.gemfire.config.admin.functions.CreateRegionFunction;
import org.springframework.data.gemfire.config.admin.functions.ListIndexesFunction;
import org.springframework.data.gemfire.config.admin.remote.RestHttpGemfireAdminTemplate;
import org.springframework.data.gemfire.function.config.EnableGemfireFunctions;
import org.springframework.data.gemfire.process.ProcessWrapper;
import org.springframework.data.gemfire.support.ConnectionEndpoint;
import org.springframework.data.gemfire.test.support.ClientServerIntegrationTestsSupport;
@@ -193,7 +189,6 @@ public class EnableClusterConfigurationIntegrationTests extends ClientServerInte
}
@CacheServerApplication(name = "EnableClusterConfigurationIntegrationTests", logLevel = LOG_LEVEL)
@EnableGemfireFunctions
static class GemFireServerConfiguration {
public static void main(String[] args) {
@@ -204,21 +199,6 @@ public class EnableClusterConfigurationIntegrationTests extends ClientServerInte
applicationContext.registerShutdownHook();
}
@Bean
CreateIndexFunction createIndexFunction() {
return new CreateIndexFunction();
}
@Bean
CreateRegionFunction createRegionFunction() {
return new CreateRegionFunction();
}
@Bean
ListIndexesFunction listIndexesFunction() {
return new ListIndexesFunction();
}
@Bean
CacheServerConfigurer cacheServerPortConfigurer(
@Value("${" + GEMFIRE_CACHE_SERVER_PORT_PROPERTY + ":40404}") int port) {