Skip to content

Commit 35d36f7

Browse files
committed
Fix call.
1 parent 7b2bb7a commit 35d36f7

File tree

3 files changed

+8
-10
lines changed

3 files changed

+8
-10
lines changed

spring-cloud-kubernetes-examples/kubernetes-loadbalancer-example/greeting-service/src/main/java/org/springframework/cloud/kubernetes/examples/GreetingController.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616

1717
package org.springframework.cloud.kubernetes.examples;
1818

19-
2019
import reactor.core.publisher.Mono;
2120

2221
import org.springframework.web.bind.annotation.GetMapping;
@@ -52,9 +51,9 @@ public GreetingController(NameService nameService) {
5251
*/
5352
@GetMapping("/greeting")
5453
public Mono<String> getGreeting(
55-
@RequestParam(value = "delay", defaultValue = "0") int delay) {
56-
return Mono
57-
.just(String.format("Hello from %s!", nameService.getName(delay)));
54+
@RequestParam(value = "delay", defaultValue = "0") int delay) {
55+
return nameService.getName(delay)
56+
.map(name -> String.format("Hello from %s!", name));
5857
}
5958

6059
}

spring-cloud-kubernetes-examples/kubernetes-loadbalancer-example/greeting-service/src/main/java/org/springframework/cloud/kubernetes/examples/NameService.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
import reactor.core.publisher.Mono;
2020

2121
import org.springframework.stereotype.Service;
22-
import org.springframework.web.reactive.function.client.ClientResponse;
2322
import org.springframework.web.reactive.function.client.WebClient;
2423

2524
/**
@@ -37,10 +36,10 @@ public NameService(WebClient.Builder webClientBuilder) {
3736
webClient = webClientBuilder.build();
3837
}
3938

40-
public Mono<ClientResponse> getName(int delay) {
39+
public Mono<String> getName(int delay) {
4140
return webClient.get()
42-
.uri("http://name-service/name?delay=%d", delay)
43-
.exchange();
41+
.uri(String.format("http://name-service/name?delay=%d", delay)).retrieve()
42+
.bodyToMono(String.class);
4443
}
4544

4645
}

spring-cloud-kubernetes-examples/kubernetes-loadbalancer-example/name-service/src/main/java/org/springframework/cloud/kubernetes/examples/NameController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,9 +51,9 @@ public String ribbonPing() {
5151
*/
5252
@GetMapping("/name")
5353
public Mono<String> getName(
54-
@RequestParam(value = "delay", defaultValue = "0") int delayValue) {
54+
@RequestParam(value = "delay", defaultValue = "0") int delayValue) {
5555
LOG.info(String.format("Returning a name '%s' with a delay '%d'", hostName,
56-
delayValue));
56+
delayValue));
5757
delay(delayValue);
5858
return Mono.just(hostName);
5959
}

0 commit comments

Comments
 (0)