From d7258c8401d70e3dce0709984295f0bdddce91df Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Wed, 11 Dec 2019 15:08:38 -0500 Subject: [PATCH] Updates to boundedElastic scheduler --- .../cloud/gateway/route/CompositeRouteDefinitionLocator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java index 58342d2c..5f29816f 100644 --- a/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java +++ b/spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/route/CompositeRouteDefinitionLocator.java @@ -52,7 +52,7 @@ public class CompositeRouteDefinitionLocator implements RouteDefinitionLocator { return this.delegates.flatMap(RouteDefinitionLocator::getRouteDefinitions) .flatMap(routeDefinition -> Mono.justOrEmpty(routeDefinition.getId()) .defaultIfEmpty(idGenerator.generateId().toString()) - .publishOn(Schedulers.elastic()).map(id -> { + .publishOn(Schedulers.boundedElastic()).map(id -> { routeDefinition.setId(id); if (log.isDebugEnabled()) { log.debug(