|
118 | 118 | import java.util.Map; |
119 | 119 | import java.util.NoSuchElementException; |
120 | 120 | import java.util.Optional; |
| 121 | +import java.util.concurrent.ThreadLocalRandom; |
121 | 122 | import java.util.function.BiFunction; |
122 | 123 | import java.util.function.Predicate; |
123 | 124 | import java.util.function.UnaryOperator; |
@@ -869,8 +870,8 @@ private static Flux<String> getPushRouteIdFromDomain(CloudFoundryClient cloudFou |
869 | 870 | .map(ResourceUtils::getId))); |
870 | 871 | } |
871 | 872 |
|
872 | | - private static Flux<String> getPushRouteIdFromRoute(CloudFoundryClient cloudFoundryClient, List<DomainSummary> availableDomains, ApplicationManifest manifest, String spaceId, RandomWords |
873 | | - randomWords) { |
| 873 | + private static Flux<String> getPushRouteIdFromRoute(CloudFoundryClient cloudFoundryClient, List<DomainSummary> availableDomains, ApplicationManifest manifest, String spaceId, |
| 874 | + RandomWords randomWords) { |
874 | 875 | return Flux.fromIterable(manifest.getRoutes()) |
875 | 876 | .flatMap(route -> RouteUtils.decomposeRoute(availableDomains, route.getRoute())) |
876 | 877 | .flatMap(decomposedRoute -> { |
@@ -1026,7 +1027,7 @@ private static Mono<Void> prepareDomainsAndRoutes(CloudFoundryClient cloudFoundr |
1026 | 1027 | } |
1027 | 1028 | } else { |
1028 | 1029 | return getPushRouteIdFromRoute(cloudFoundryClient, availableDomains, manifest, spaceId, randomWords) |
1029 | | - .flatMap(routeId -> requestAssociateRoute(cloudFoundryClient, applicationId, routeId)) |
| 1030 | + .flatMapSequential(routeId -> requestAssociateRoute(cloudFoundryClient, applicationId, routeId), 1) |
1030 | 1031 | .then(); |
1031 | 1032 | } |
1032 | 1033 | } |
|
0 commit comments