diff --git a/spring-cloud-gateway-server/src/test/java/org/springframework/cloud/gateway/filter/factory/SpringCloudCircuitBreakerTestConfig.java b/spring-cloud-gateway-server/src/test/java/org/springframework/cloud/gateway/filter/factory/SpringCloudCircuitBreakerTestConfig.java index ac65ee68..73d1bc4e 100644 --- a/spring-cloud-gateway-server/src/test/java/org/springframework/cloud/gateway/filter/factory/SpringCloudCircuitBreakerTestConfig.java +++ b/spring-cloud-gateway-server/src/test/java/org/springframework/cloud/gateway/filter/factory/SpringCloudCircuitBreakerTestConfig.java @@ -120,14 +120,12 @@ public class SpringCloudCircuitBreakerTestConfig { .circuitBreaker(config -> config.setName("stalling-command"))) .uri(uri)) .route("circuitbreaker_fallback_test_reset_exchange", - r -> r.host("**.circuitbreakerresetexchange.org") - .filters(f -> f.circuitBreaker(config -> config.setName("fallbackcmd") + r -> r.host("**.circuitbreakerresetexchange.org").filters(f -> f + .circuitBreaker(config -> config.setName("fallbackcmd") .setFallbackUri("forward:/resetExchangeFallbackController")) - .filter((exchange, chain) -> chain.filter(exchange) - .then(Mono.defer(() -> - !exchange.getResponse().isCommitted() ? - Mono.error(new Exception("Some Random Exception")) : - Mono.empty())))) + .filter((exchange, chain) -> chain.filter(exchange) + .then(Mono.defer(() -> !exchange.getResponse().isCommitted() + ? Mono.error(new Exception("Some Random Exception")) : Mono.empty())))) .uri(uri)) .build(); }