diff --git a/spring-reactor/src/main/java/com/baeldung/Config.java b/spring-reactor/src/main/java/com/baeldung/Config.java index 28f40dda02..ac1bfb3945 100644 --- a/spring-reactor/src/main/java/com/baeldung/Config.java +++ b/spring-reactor/src/main/java/com/baeldung/Config.java @@ -2,7 +2,6 @@ package com.baeldung; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; - import reactor.Environment; import reactor.bus.EventBus; @@ -10,13 +9,12 @@ import reactor.bus.EventBus; public class Config { @Bean - Environment env() { + public Environment env() { return Environment.initializeIfEmpty().assignErrorJournal(); } @Bean - EventBus createEventBus(Environment env) { + public EventBus createEventBus(Environment env) { return EventBus.create(env, Environment.THREAD_POOL); } - } diff --git a/spring-reactor/src/main/java/com/baeldung/NotificationApplication.java b/spring-reactor/src/main/java/com/baeldung/NotificationApplication.java index a15b2e1818..6f0c8cdf96 100644 --- a/spring-reactor/src/main/java/com/baeldung/NotificationApplication.java +++ b/spring-reactor/src/main/java/com/baeldung/NotificationApplication.java @@ -26,5 +26,4 @@ public class NotificationApplication implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(NotificationApplication.class, args); } - } diff --git a/spring-reactor/src/test/java/com/baeldung/NotificationApplicationIntegrationTest.java b/spring-reactor/src/test/java/com/baeldung/NotificationApplicationIntegrationTest.java index 5ad9427397..6f6b39b2d5 100644 --- a/spring-reactor/src/test/java/com/baeldung/NotificationApplicationIntegrationTest.java +++ b/spring-reactor/src/test/java/com/baeldung/NotificationApplicationIntegrationTest.java @@ -19,6 +19,4 @@ public class NotificationApplicationIntegrationTest { RestTemplate restTemplate = new RestTemplate(); restTemplate.getForObject("http://localhost:" + port + "/startNotification/10", String.class); } - - }