@Configuration
@ComponentScan
@EnableReactor
public static class ReactorConfiguration {
@Bean public EventBus eventBus() {
<BUG>return EventBus.config()
.env(get())
.dispatcher(Environment.SHARED)</BUG>
.get();
}

@Configuration
@ComponentScan
@EnableReactor
public static class ReactorConfiguration {
@Bean public EventBus eventBus() {
return EventBus.config()
.processor(Processors.topic())
.get();
}
