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

Bumping versions

Browse Source
This commit is contained in:
spring-builds
2025-05-21 11:04:41 +00:00
parent 0c9d8e4a5d
commit 4ea6e6c914
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
spring-cloud-circuitbreaker-spring-retry/src/test/java/org/springframework/cloud/circuitbreaker/springretry/SpringRetryCircuitBreakerIntegrationTest.java
View File

@@ -90,30 +90,31 @@ class SpringRetryCircuitBreakerIntegrationTest {
@Bean
Customizer<SpringRetryCircuitBreakerFactory> factoryCustomizer() {
return factory -> {
CircuitBreakerRetryPolicy circuitBreakerRetryPolicy = new CircuitBreakerRetryPolicy(new SimpleRetryPolicy(2));
CircuitBreakerRetryPolicy circuitBreakerRetryPolicy = new CircuitBreakerRetryPolicy(
new SimpleRetryPolicy(2));
circuitBreakerRetryPolicy.setOpenTimeout(1000);
circuitBreakerRetryPolicy.setResetTimeout(1000);
factory.configureDefault(
id -> new SpringRetryConfigBuilder(id).retryPolicy(circuitBreakerRetryPolicy).build());
id -> new SpringRetryConfigBuilder(id).retryPolicy(circuitBreakerRetryPolicy).build());
factory.configure(builder -> builder.retryPolicy(new SimpleRetryPolicy(1)).build(), "slow");
factory
.addRetryTemplateCustomizers(retryTemplate -> retryTemplate.registerListener(new RetryListener() {
@Override
public <T, E extends Throwable> boolean open(RetryContext context,
RetryCallback<T, E> callback) {
RetryCallback<T, E> callback) {
return false;
}
@Override
public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback,
Throwable throwable) {
Throwable throwable) {
}
@Override
public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback,
Throwable throwable) {
Throwable throwable) {
}
}));