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

Set the host & port on the ProcessWrapper representing the GemFire/Geode JVM server process forked by the STDG framework.

Browse Source 
Return the ProcessWrapper representing the forked GemFire/Geode JVM server process from the startGemFireServer(..) and startGeodeServer(..) methods.

Resolves gh-14.
This commit is contained in:
John Blum
2021-10-28 14:08:26 -07:00
parent d9bfbd479d
commit 81589fab22
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-data-geode-test/src/main/java/org/springframework/data/gemfire/tests/integration/ForkingClientServerIntegrationTestsSupport.java
View File

@@ -16,6 +16,7 @@
package org.springframework.data.gemfire.tests.integration;
import java.io.IOException;
import java.net.InetAddress;
import java.time.Duration;
import java.util.ArrayList;
import java.util.Arrays;
@@ -67,7 +68,7 @@ public abstract class ForkingClientServerIntegrationTestsSupport extends ClientS
private static ProcessWrapper gemfireServer;
public static void startGemFireServer(@NonNull Class<?> gemfireServerConfigurationClass, String... arguments)
public static ProcessWrapper startGemFireServer(@NonNull Class<?> gemfireServerConfigurationClass, String... arguments)
throws IOException {
int availablePort = setAndGetPoolPortProperty(setAndGetCacheServerPortProperty(findAndReserveAvailablePort()));
@@ -76,15 +77,23 @@ public abstract class ForkingClientServerIntegrationTestsSupport extends ClientS
argumentList.add(String.format("-D%s=%d", GEMFIRE_CACHE_SERVER_PORT_PROPERTY, availablePort));
setGemFireServerProcess(run(gemfireServerConfigurationClass, argumentList.toArray(new String[0])));
ProcessWrapper gemfireServerProcessWrapper =
run(gemfireServerConfigurationClass, argumentList.toArray(new String[0]));
gemfireServerProcessWrapper = gemfireServerProcessWrapper
.runningOn(InetAddress.getLocalHost().getHostAddress())
.listeningOn(availablePort);
setGemFireServerProcess(gemfireServerProcessWrapper);
waitForServerToStart("localhost", availablePort);
return gemfireServerProcessWrapper;
}
public static void startGeodeServer(@NonNull Class<?> geodeServerConfigurationClass, String... arguments)
public static ProcessWrapper startGeodeServer(@NonNull Class<?> geodeServerConfigurationClass, String... arguments)
throws IOException {
startGemFireServer(geodeServerConfigurationClass, arguments);
return startGemFireServer(geodeServerConfigurationClass, arguments);
}
protected static int setAndGetCacheServerPortProperty(int port) {