|
25 | 25 | import org.springframework.boot.autoconfigure.EnableAutoConfiguration; |
26 | 26 | import org.springframework.boot.test.context.SpringBootTest; |
27 | 27 | import org.springframework.cloud.circuitbreaker.resilience4j.ReactiveResilience4JCircuitBreakerFactory; |
| 28 | +import org.springframework.cloud.circuitbreaker.resilience4j.ReactiveResilience4jBulkheadProvider; |
28 | 29 | import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JCircuitBreakerFactory; |
| 30 | +import org.springframework.cloud.circuitbreaker.resilience4j.Resilience4JConfigurationProperties; |
29 | 31 | import org.springframework.cloud.client.circuitbreaker.Customizer; |
30 | 32 | import org.springframework.cloud.gateway.filter.GatewayFilter; |
31 | 33 | import org.springframework.cloud.gateway.test.BaseWebClientTests; |
|
40 | 42 |
|
41 | 43 | import static org.assertj.core.api.Assertions.assertThat; |
42 | 44 | import static org.hamcrest.core.StringContains.containsString; |
| 45 | +import static org.mockito.Mockito.mock; |
43 | 46 | import static org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT; |
44 | 47 |
|
45 | 48 | /** |
@@ -102,7 +105,8 @@ public void toStringFormat() { |
102 | 105 | .setFallbackUri("forward:/myfallback"); |
103 | 106 | GatewayFilter filter = new SpringCloudCircuitBreakerResilience4JFilterFactory( |
104 | 107 | new ReactiveResilience4JCircuitBreakerFactory(CircuitBreakerRegistry.ofDefaults(), |
105 | | - TimeLimiterRegistry.ofDefaults()), |
| 108 | + TimeLimiterRegistry.ofDefaults(), mock(ReactiveResilience4jBulkheadProvider.class), |
| 109 | + new Resilience4JConfigurationProperties()), |
106 | 110 | null) |
107 | 111 | .apply(config); |
108 | 112 | assertThat(filter.toString()).contains("myname").contains("forward:/myfallback"); |
|
0 commit comments