SpringCloud/spring-cloud-core-tests
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Makes config server run on a random port.

Browse Source
This commit is contained in:
spencergibb
2020-08-11 14:58:57 -04:00
parent 3794cd2de3
commit befb2cfd33
2 changed files with 11 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
config-retry/src/test/java/apps/ConfigServer.java
View File

@@ -38,7 +38,7 @@ public class ConfigServer {
return new SpringApplicationBuilder(ConfigServer.class)
.bannerMode(Mode.OFF)
.profiles("native")
.properties("server.port=8888",
.properties(
"spring.cloud.config.server.native.searchLocation:file:./src/test/resources/config/")
.run(args);
}

25
config-retry/src/test/java/demo/ConfigClientRetryApplicationTests.java
View File

@@ -26,6 +26,7 @@ import org.springframework.retry.support.RetryTemplate;
import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.util.ReflectionTestUtils;
import org.springframework.util.SocketUtils;
import apps.ConfigServer;
@@ -43,6 +44,8 @@ public class ConfigClientRetryApplicationTests {
@BeforeClass
public static void delayConfigServer() {
int port = SocketUtils.findAvailableTcpPort();
System.setProperty("spring.cloud.config.uri", "http://localhost:" + port);
Executors.newSingleThreadExecutor().execute(new Runnable() {
@Override
public void run() {
@@ -51,7 +54,7 @@ public class ConfigClientRetryApplicationTests {
}
catch (InterruptedException e) {
}
context = ConfigServer.start();
context = ConfigServer.start("--server.port=" + port);
}
});
}
@@ -75,20 +78,12 @@ public class ConfigClientRetryApplicationTests {
Object obj = delegates
.values().iterator().next();
RetryTemplate retryTemplate = null;
if(RetryOperationsInterceptor.class.isInstance(obj)) {
//Prior to Boot 1.5.10
RetryOperationsInterceptor interceptor = (RetryOperationsInterceptor)obj;
retryTemplate = (RetryTemplate) ReflectionTestUtils.getField(
interceptor, "retryOperations");
} else if(Map.class.isInstance(obj)) {
//Boot 1.5.10 and later
Object[] methodInterceptors = ((Map)obj).values().toArray();
RetryOperationsInterceptor interceptor = (RetryOperationsInterceptor)methodInterceptors[0];
retryTemplate = (RetryTemplate)ReflectionTestUtils.getField(
interceptor, "retryOperations");;
} else {
fail("Could not find RetryTemplate");
}
Object[] methodInterceptors = ((Map)obj).values().toArray();
RetryOperationsInterceptor interceptor = (RetryOperationsInterceptor)methodInterceptors[0];
retryTemplate = (RetryTemplate)ReflectionTestUtils.getField(
interceptor, "retryOperations");;
ExponentialBackOffPolicy backoff = (ExponentialBackOffPolicy) ReflectionTestUtils
.getField(retryTemplate, "backOffPolicy");
assertEquals(3000, backoff.getInitialInterval());