Merge pull request #56 from andmagom/feature/commons-refactor

Common classes separation from RabbitMQ Implementation

Author: dbuos

acceptance/async-tests/async-tests.gradle

@@ -1,5 +1,5 @@
 dependencies {
-    compile project(":async-commons-starter")
+    compile project(":async-commons-rabbit-starter")
     compile('org.springframework.boot:spring-boot-starter')
 }
 

acceptance/async-tests/src/test/java/org/reactivecommons/test/DirectGatewayPerfTest.java

@@ -3,7 +3,7 @@
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.Test;
 import org.reactivecommons.api.domain.Command;
-import org.reactivecommons.async.impl.RabbitDirectAsyncGateway;
+import org.reactivecommons.async.rabbit.RabbitDirectAsyncGateway;
 import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;

acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleDirectCommunicationTest.java

@@ -14,7 +14,6 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Bean;
-import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.UnicastProcessor;
 import reactor.test.StepVerifier;

acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleEventNotificationTest.java

@@ -12,7 +12,6 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Bean;
-import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.UnicastProcessor;
 import reactor.test.StepVerifier;
 

acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java

@@ -13,7 +13,6 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Bean;
-import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.UnicastProcessor;
 import reactor.test.StepVerifier;

acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/ParallelOnBlockingInSubscriptionTimeTest.java

@@ -14,7 +14,6 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Bean;
-import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.UnicastProcessor;
 import reactor.test.StepVerifier;

acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/SimpleCommandHandlePerfTest.java

@@ -14,7 +14,6 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Bean;
-import org.springframework.test.context.junit4.SpringRunner;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.UnicastProcessor;
 import reactor.test.StepVerifier;

async/async-commons-standalone/async-commons-standalone.gradle

@@ -1,9 +1,9 @@
-package org.reactivecommons.async.impl;
+package org.reactivecommons.async.commons;
 
 
 import org.reactivecommons.api.domain.Command;
-import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.api.handlers.CommandHandler;
+import org.reactivecommons.async.commons.communications.Message;
 import reactor.core.publisher.Mono;
 
 import java.util.function.Function;

async/async-commons/src/main/java/org/reactivecommons/async/impl/CommandExecutor.java renamed to async/async-commons/src/main/java/org/reactivecommons/async/commons/CommandExecutor.java

@@ -1,6 +1,6 @@
-package org.reactivecommons.async.impl;
+package org.reactivecommons.async.commons;
 
-import org.reactivecommons.async.impl.communications.Message;
+import org.reactivecommons.async.commons.communications.Message;
 import reactor.core.publisher.Mono;
 
 public interface DiscardNotifier {