23 lines
475 B
Java
23 lines
475 B
Java
|
package com.baeldung;
|
||
|
|
|
||
|
|
import org.springframework.context.annotation.Bean;
|
||
|
|
import org.springframework.context.annotation.Configuration;
|
||
|
|
|
||
|
|
import reactor.Environment;
|
||
|
|
import reactor.bus.EventBus;
|
||
|
|
|
||
|
|
@Configuration
|
||
|
|
public class Config {
|
||
|
|
|
||
|
|
@Bean
|
||
|
|
Environment env() {
|
||
|
|
return Environment.initializeIfEmpty().assignErrorJournal();
|
||
|
|
}
|
||
|
|
|
||
|
|
@Bean
|
||
|
|
EventBus createEventBus(Environment env) {
|
||
|
|
return EventBus.create(env, Environment.THREAD_POOL);
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|