Disables retry and retry tests.
See gh-1891
This commit is contained in:
@@ -234,8 +234,8 @@ public class RetryGatewayFilterFactory
|
||||
if (retry != null) {
|
||||
// retryWhen returns a Mono<Void>
|
||||
// retry needs to go before repeat
|
||||
publisher = ((Mono<Void>) publisher)
|
||||
.retryWhen(retry.withApplicationContext(exchange));
|
||||
publisher = Mono.empty(); // ((Mono<Void>) publisher)
|
||||
// FIXME: .retryWhen(retry.withApplicationContext(exchange));
|
||||
}
|
||||
if (repeat != null) {
|
||||
// repeatWhen returns a Flux<Void>
|
||||
|
||||
@@ -25,6 +25,7 @@ import java.util.concurrent.atomic.AtomicInteger;
|
||||
import org.apache.commons.logging.Log;
|
||||
import org.apache.commons.logging.LogFactory;
|
||||
import org.hamcrest.CoreMatchers;
|
||||
import org.junit.Ignore;
|
||||
import org.junit.Rule;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
@@ -77,12 +78,14 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
public final OutputCaptureRule capture = new OutputCaptureRule();
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryFilterGet() {
|
||||
testClient.get().uri("/retry?key=get").exchange().expectStatus().isOk()
|
||||
.expectBody(String.class).isEqualTo("3");
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryFilterFailure() {
|
||||
testClient.mutate().responseTimeout(Duration.ofSeconds(10)).build().get()
|
||||
.uri("/retryalwaysfail?key=getjavafailure&count=4")
|
||||
@@ -93,6 +96,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryWithBackoff() {
|
||||
// @formatter:off
|
||||
testClient.get()
|
||||
@@ -105,6 +109,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryFilterGetJavaDsl() {
|
||||
testClient.get().uri("/retry?key=getjava&count=2")
|
||||
.header(HttpHeaders.HOST, "www.retryjava.org").exchange().expectStatus()
|
||||
@@ -112,6 +117,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryFilterPost() {
|
||||
testClient.post().uri("/retrypost?key=postconfig&expectedbody=HelloConfig")
|
||||
.header(HttpHeaders.HOST, "www.retrypostconfig.org")
|
||||
@@ -120,6 +126,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryFilterPostJavaDsl() {
|
||||
testClient.post().uri("/retrypost?key=post&expectedbody=Hello")
|
||||
.header(HttpHeaders.HOST, "www.retryjava.org").bodyValue("Hello")
|
||||
@@ -127,6 +134,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retryFilterPostOneTime() {
|
||||
testClient.post().uri(
|
||||
"/retrypost?key=retryFilterPostOneTime&expectedbody=HelloGateway&count=1")
|
||||
@@ -138,6 +146,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void retriesSleepyRequest() throws Exception {
|
||||
testClient.mutate().responseTimeout(Duration.ofSeconds(10)).build().get()
|
||||
.uri("/sleep?key=sleepyRequest&millis=3000")
|
||||
@@ -148,7 +157,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
// @Ignore // FIXME: https://github.com/spring-cloud/spring-cloud-gateway/issues/1675
|
||||
@Ignore
|
||||
public void shouldNotRetryWhenSleepyRequestPost() throws Exception {
|
||||
testClient.mutate().responseTimeout(Duration.ofSeconds(10)).build().post()
|
||||
.uri("/sleep?key=notRetriesSleepyRequestPost&millis=3000")
|
||||
@@ -160,6 +169,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void shouldNotRetryWhenSleepyRequestPostWithBody() throws Exception {
|
||||
testClient.mutate().responseTimeout(Duration.ofSeconds(10)).build().post()
|
||||
.uri("/sleep?key=notRetriesSleepyRequestPostWithBody&millis=3000")
|
||||
@@ -172,6 +182,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void shouldRetryWhenSleepyRequestGet() throws Exception {
|
||||
testClient.mutate().responseTimeout(Duration.ofSeconds(10)).build().get()
|
||||
.uri("/sleep?key=sleepyRequestGet&millis=3000")
|
||||
@@ -182,6 +193,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
@SuppressWarnings("unchecked")
|
||||
public void retryFilterLoadBalancedWithMultipleServers() {
|
||||
String host = "www.retrywithloadbalancer.org";
|
||||
@@ -196,6 +208,7 @@ public class RetryGatewayFilterFactoryIntegrationTests extends BaseWebClientTest
|
||||
}
|
||||
|
||||
@Test
|
||||
@Ignore
|
||||
public void toStringFormat() {
|
||||
RetryConfig config = new RetryConfig();
|
||||
config.setRetries(4);
|
||||
|
||||
Reference in New Issue
Block a user