BAEL-19928: Refactor spring-reactor module

spring-reactor/src/main/java/com/baeldung/NotificationApplication.java

@@ -1,24 +1,16 @@
 package com.baeldung;
 
+import com.baeldung.consumer.NotificationConsumer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
-import org.springframework.context.annotation.ComponentScan;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Import;
-
-import com.baeldung.consumer.NotificationConsumer;
-
+import org.springframework.boot.autoconfigure.SpringBootApplication;
 import reactor.bus.EventBus;
 
 import static reactor.bus.selector.Selectors.$;
 
-@Configuration
-@EnableAutoConfiguration
-@ComponentScan
-@Import(Config.class)
-public class Application implements CommandLineRunner {
+@SpringBootApplication
+public class NotificationApplication implements CommandLineRunner {
 
     @Autowired
     private EventBus eventBus;
@@ -32,7 +24,7 @@ public class Application implements CommandLineRunner {
     }
 
     public static void main(String[] args) {
-        SpringApplication.run(Application.class, args);
+        SpringApplication.run(NotificationApplication.class, args);
     }
 
 }

spring-reactor/src/main/java/com/baeldung/consumer/NotificationConsumer.java

@@ -3,7 +3,7 @@ package com.baeldung.consumer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import com.baeldung.doman.NotificationData;
+import com.baeldung.domain.NotificationData;
 import com.baeldung.service.NotificationService;
 
 import reactor.bus.Event;

spring-reactor/src/main/java/com/baeldung/controller/NotificationController.java

@@ -5,7 +5,7 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.RestController;
 
-import com.baeldung.doman.NotificationData;
+import com.baeldung.domain.NotificationData;
 
 import reactor.bus.Event;
 import reactor.bus.EventBus;

spring-reactor/src/main/java/com/baeldung/domain/NotificationData.java

@@ -1,4 +1,4 @@
-package com.baeldung.doman;
+package com.baeldung.domain;
 
 public class NotificationData {
 

spring-reactor/src/main/java/com/baeldung/service/NotificationService.java

@@ -1,6 +1,6 @@
 package com.baeldung.service;
 
-import com.baeldung.doman.NotificationData;
+import com.baeldung.domain.NotificationData;
 
 public interface NotificationService {
 

spring-reactor/src/main/java/com/baeldung/service/impl/NotificationServiceimpl.java

@@ -2,7 +2,7 @@ package com.baeldung.service.impl;
 
 import org.springframework.stereotype.Service;
 
-import com.baeldung.doman.NotificationData;
+import com.baeldung.domain.NotificationData;
 import com.baeldung.service.NotificationService;
 
 @Service

spring-reactor/src/test/java/com/baeldung/DataLoaderLiveTest.java

@@ -1,14 +0,0 @@
-package com.baeldung;
-
-import org.junit.Test;
-import org.springframework.web.client.RestTemplate;
-
-public class DataLoaderLiveTest {
-
-    @Test
-    public void exampleTest() {
-        RestTemplate restTemplate = new RestTemplate();
-        restTemplate.getForObject("http://localhost:8080/startNotification/10", String.class);
-    }
-
-}

spring-reactor/src/test/java/com/baeldung/NotificationApplicationIntegrationTest.java

@@ -0,0 +1,24 @@
+package com.baeldung;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.web.server.LocalServerPort;
+import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.web.client.RestTemplate;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+public class NotificationApplicationIntegrationTest {
+
+    @LocalServerPort
+    private int port;
+
+    @Test
+    public void givenAppStarted_whenNotificationTasksSubmitted_thenProcessed() {
+        RestTemplate restTemplate = new RestTemplate();
+        restTemplate.getForObject("http://localhost:" + port + "/startNotification/10", String.class);
+    }
+
+
+}

spring-reactor/src/test/java/org/baeldung/SpringContextTest.java

@@ -5,10 +5,10 @@ import org.junit.runner.RunWith;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
-import com.baeldung.Application;
+import com.baeldung.NotificationApplication;
 
 @RunWith(SpringRunner.class)
-@SpringBootTest(classes = Application.class)
+@SpringBootTest(classes = NotificationApplication.class)
 public class SpringContextTest {
 
     @Test