Add slow endpoint

martin-tarjanyi · Mar 22, 2018 · 933df1b · 933df1b
1 parent 011b911
commit 933df1b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/src/main/java/com/example/webfluxdemo/controller/PersonController.java b/src/main/java/com/example/webfluxdemo/controller/PersonController.java
@@ -45,6 +45,13 @@ public Flux<Person> getAllAsStream()
         return mongoRepository.findAll().delayElements(Duration.ofMillis(1000));
     }
 
+    @GetMapping("/slow")
+    public Mono<String> slowEndpoint()
+    {
+        return Mono.delay(Duration.ofSeconds(3))
+                   .then(Mono.just(Thread.currentThread().getName()));
+    }
+
     @ResponseBody
     @ExceptionHandler(IllegalArgumentException.class)
     public ResponseEntity<?> response()

diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -1,2 +1,2 @@
-spring.data.mongodb.host=192.168.99.100
-spring.redis.host=192.168.99.100
+spring.data.mongodb.host=localhost
+spring.redis.host=localhost