iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BAEL-19928: Further minor improvements

Browse Source
This commit is contained in:
Krzysztof Woyke 2019-12-19 08:28:26 +01:00
parent 7434ce7775
commit dee493a6eb
3 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
spring-reactor/src/main/java/com/baeldung/Config.java
View File

@ -2,7 +2,6 @@ package com.baeldung;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import reactor.Environment; import reactor.Environment;
import reactor.bus.EventBus; import reactor.bus.EventBus;
@ -10,13 +9,12 @@ import reactor.bus.EventBus;
public class Config { public class Config {
@Bean @Bean
Environment env() { public Environment env() {
return Environment.initializeIfEmpty().assignErrorJournal(); return Environment.initializeIfEmpty().assignErrorJournal();
} }
@Bean @Bean
EventBus createEventBus(Environment env) { public EventBus createEventBus(Environment env) {
return EventBus.create(env, Environment.THREAD_POOL); return EventBus.create(env, Environment.THREAD_POOL);
} }
} }

1
spring-reactor/src/main/java/com/baeldung/NotificationApplication.java
View File

@ -26,5 +26,4 @@ public class NotificationApplication implements CommandLineRunner {
public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(NotificationApplication.class, args); SpringApplication.run(NotificationApplication.class, args);
} }
} }

2
spring-reactor/src/test/java/com/baeldung/NotificationApplicationIntegrationTest.java
View File

@ -19,6 +19,4 @@ public class NotificationApplicationIntegrationTest {
RestTemplate restTemplate = new RestTemplate(); RestTemplate restTemplate = new RestTemplate();
restTemplate.getForObject("http://localhost:" + port + "/startNotification/10", String.class); restTemplate.getForObject("http://localhost:" + port + "/startNotification/10", String.class);
} }
} }