From 7f0d9904d74a2aec714ce076133b4be3b8bbe3c4 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Tue, 22 Aug 2017 16:56:30 -0600 Subject: [PATCH] Disable pool for testing --- .../cloud/gateway/test/BaseWebClientTests.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/test/BaseWebClientTests.java b/spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/test/BaseWebClientTests.java index b97f369a..284ea594 100644 --- a/spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/test/BaseWebClientTests.java +++ b/spring-cloud-gateway-core/src/test/java/org/springframework/cloud/gateway/test/BaseWebClientTests.java @@ -22,6 +22,7 @@ import java.time.Duration; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.function.Consumer; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -53,6 +54,8 @@ import static org.springframework.cloud.gateway.support.ServerWebExchangeUtils.G import static org.springframework.cloud.gateway.support.ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR; import reactor.core.publisher.Mono; +import reactor.ipc.netty.http.client.HttpClientOptions; +import reactor.ipc.netty.resources.PoolResources; /** * @author Spencer Gibb @@ -167,6 +170,14 @@ public class BaseWebClientTests { return ResponseEntity.status(status).body("Failed with "+status); } + @Bean + public Consumer nettyClientOptions() { + return opts -> { + opts.poolResources(PoolResources.elastic("proxy")); + opts.disablePool(); + }; + } + @Bean @Order(500) public GlobalFilter modifyResponseFilter() {