Fixed for a future

opentable · Jan 9, 2020 · a341c41 · a341c41 · opentable-devops · Jan 9, 2020
1 parent 36801d2
commit a341c41
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...reactive/src/test/java/com/opentable/server/reactive/TestReactiveServerConfiguration.java b/...reactive/src/test/java/com/opentable/server/reactive/TestReactiveServerConfiguration.java
@@ -21,6 +21,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -60,7 +61,7 @@ WebClient webClient() {
      * reactive operations from different requests are scheduled on threads that were previously used by another
      * request.
      */
-    @Bean
+    @Bean("parallelScheduler")
     Scheduler getScheduler() {
         return Schedulers.newParallel("parallel-scheduler", 3);
     }
@@ -75,6 +76,7 @@ public static class MyResource {
         private WebClient webClient;
 
         @Autowired
+        @Qualifier("parallelScheduler")
         private Scheduler parallelScheduler;
 
         @RequestMapping("test")