Updates to boundedElastic scheduler

This commit is contained in:
Spencer Gibb
2019-12-11 15:08:38 -05:00
parent b50a74bb35
commit d7258c8401

View File

@@ -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(