updating with test case (#947)

* Update pom.xml

* Add files via upload

* Update Application.java

* Create DataLoader.java

* Create DataLoader.java

* Delete DataLoader.java
This commit is contained in:
Abhinab Kanrar
2017-01-03 22:23:24 +05:30
committed by Grzegorz Piwowarek
parent 4018d45a2c
commit 99e86c5f19
4 changed files with 48 additions and 12 deletions

View File

@@ -0,0 +1,22 @@
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);
}
}