Refactor reactive commons

andmagom · andmagom · commit a679f18f9199 · 2021-03-16T14:49:30.000-05:00
diff --git a/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/CommandListenersConfig.java b/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/CommandListenersConfig.java
@@ -1,7 +1,7 @@
 package org.reactivecommons.async.impl.config;
 
 import lombok.RequiredArgsConstructor;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.config.props.AsyncProps;
diff --git a/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/EventListenersConfig.java b/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/EventListenersConfig.java
@@ -1,7 +1,7 @@
 package org.reactivecommons.async.impl.config;
 
 import lombok.RequiredArgsConstructor;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.config.props.AsyncProps;
diff --git a/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/NotificacionListenersConfig.java b/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/NotificacionListenersConfig.java
@@ -1,7 +1,7 @@
 package org.reactivecommons.async.impl.config;
 
 import lombok.RequiredArgsConstructor;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.config.props.AsyncProps;
diff --git a/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/QueryListenerConfig.java b/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/QueryListenerConfig.java
@@ -1,7 +1,7 @@
 package org.reactivecommons.async.impl.config;
 
 import lombok.RequiredArgsConstructor;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
diff --git a/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java b/async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java
@@ -23,6 +23,7 @@
 import org.reactivecommons.async.impl.converters.json.JacksonMessageConverter;
 import org.reactivecommons.async.impl.converters.json.ObjectMapperSupplier;
 import org.reactivecommons.async.impl.ext.CustomErrorReporter;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
diff --git a/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/CommandListenersConfigTest.java b/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/CommandListenersConfigTest.java
@@ -6,7 +6,7 @@
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.junit.jupiter.MockitoExtension;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
diff --git a/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/EventListenersConfigTest.java b/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/EventListenersConfigTest.java
@@ -4,7 +4,7 @@
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
diff --git a/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/NotificacionListenersConfigTest.java b/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/NotificacionListenersConfigTest.java
@@ -4,7 +4,7 @@
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
diff --git a/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/QueryListenerConfigTest.java b/async/async-commons-starter/src/test/java/org/reactivecommons/async/impl/config/QueryListenerConfigTest.java
@@ -4,7 +4,7 @@
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/CommandExecutor.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/CommandExecutor.java
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/DiscardNotifier.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/DiscardNotifier.java
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/EventExecutor.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/EventExecutor.java
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/FallbackStrategy.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/FallbackStrategy.java
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/QueryExecutor.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/QueryExecutor.java
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/RabbitDiscardNotifier.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/RabbitDiscardNotifier.java
@@ -8,6 +8,7 @@
 import org.reactivecommons.api.domain.DomainEventBus;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.exceptions.MessageConversionException;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import reactor.core.publisher.Mono;
 
 import java.io.IOException;
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationCommandListener.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationCommandListener.java
@@ -3,11 +3,11 @@
 import com.rabbitmq.client.AMQP;
 import lombok.extern.java.Log;
 import org.reactivecommons.api.domain.Command;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.converters.MessageConverter;
 import org.reactivecommons.async.api.handlers.registered.RegisteredCommandHandler;
-import org.reactivecommons.async.impl.CommandExecutor;
+import org.reactivecommons.async.parent.CommandExecutor;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.RabbitMessage;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
@@ -17,7 +17,6 @@
 import reactor.rabbitmq.AcknowledgableDelivery;
 import reactor.rabbitmq.BindingSpecification;
 import reactor.rabbitmq.ExchangeSpecification;
-import reactor.rabbitmq.QueueSpecification;
 
 import java.util.Optional;
 import java.util.function.Function;
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationEventListener.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationEventListener.java
@@ -3,11 +3,11 @@
 import com.rabbitmq.client.AMQP;
 import lombok.extern.java.Log;
 import org.reactivecommons.api.domain.DomainEvent;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.converters.MessageConverter;
 import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener;
-import org.reactivecommons.async.impl.EventExecutor;
+import org.reactivecommons.async.parent.EventExecutor;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationNotificationListener.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationNotificationListener.java
@@ -4,8 +4,8 @@
 import lombok.extern.java.Log;
 import org.reactivecommons.api.domain.DomainEvent;
 import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener;
-import org.reactivecommons.async.impl.DiscardNotifier;
-import org.reactivecommons.async.impl.EventExecutor;
+import org.reactivecommons.async.parent.DiscardNotifier;
+import org.reactivecommons.async.parent.EventExecutor;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationQueryListener.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationQueryListener.java
@@ -3,10 +3,9 @@
 import com.rabbitmq.client.AMQP;
 import lombok.extern.java.Log;
 import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
-import org.reactivecommons.async.impl.Headers;
-import org.reactivecommons.async.impl.QueryExecutor;
+import org.reactivecommons.async.parent.QueryExecutor;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
@@ -22,7 +21,6 @@
 import java.util.Optional;
 import java.util.function.Function;
 
-import static java.lang.Boolean.TRUE;
 import static java.util.Optional.ofNullable;
 import static org.reactivecommons.async.impl.Headers.*;
 
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/GenericMessageListener.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/GenericMessageListener.java
@@ -2,8 +2,8 @@
 
 import com.rabbitmq.client.AMQP;
 import lombok.extern.java.Log;
-import org.reactivecommons.async.impl.DiscardNotifier;
-import org.reactivecommons.async.impl.FallbackStrategy;
+import org.reactivecommons.async.parent.DiscardNotifier;
+import org.reactivecommons.async.parent.FallbackStrategy;
 import org.reactivecommons.async.impl.RabbitMessage;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/impl/QueryExecutorTest.java b/async/async-commons/src/test/java/org/reactivecommons/async/impl/QueryExecutorTest.java
@@ -11,6 +11,7 @@
 import org.reactivecommons.async.helpers.SampleClass;
 import org.reactivecommons.async.helpers.TestStubs;
 import org.reactivecommons.async.impl.communications.Message;
+import org.reactivecommons.async.parent.QueryExecutor;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
 
diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/ApplicationCommandListenerPerfTest.java b/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/ApplicationCommandListenerPerfTest.java
@@ -16,7 +16,7 @@
 import org.reactivecommons.async.api.DefaultCommandHandler;
 import org.reactivecommons.async.api.HandlerRegistry;
 import org.reactivecommons.async.api.handlers.registered.RegisteredCommandHandler;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/ApplicationQueryListenerTest.java b/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/ApplicationQueryListenerTest.java
@@ -9,7 +9,7 @@
 import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
 import org.reactivecommons.async.helpers.SampleClass;
 import org.reactivecommons.async.helpers.TestStubs;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/GenericMessageListenerPerfTest.java b/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/GenericMessageListenerPerfTest.java
@@ -12,7 +12,7 @@
 import org.mockito.Mockito;
 import org.mockito.junit.jupiter.MockitoExtension;
 import org.reactivecommons.api.domain.Command;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.communications.Message;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/ListenerReporterTestSuperClass.java b/async/async-commons/src/test/java/org/reactivecommons/async/impl/listeners/ListenerReporterTestSuperClass.java
@@ -13,7 +13,7 @@
 import org.reactivecommons.async.api.handlers.registered.RegisteredCommandHandler;
 import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener;
 import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
-import org.reactivecommons.async.impl.DiscardNotifier;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
 import org.reactivecommons.async.impl.Headers;
 import org.reactivecommons.async.impl.communications.Message;
diff --git a/async/async-parent/src/main/java/org/reactivecommons/async/parent/CommandExecutor.java b/async/async-parent/src/main/java/org/reactivecommons/async/parent/CommandExecutor.java
@@ -2,8 +2,8 @@
 
 
 import org.reactivecommons.api.domain.Command;
-import org.reactivecommons.async.api.handlers.CommandHandler;
 import org.reactivecommons.async.impl.communications.Message;
+import org.reactivecommons.async.api.handlers.CommandHandler;
 import reactor.core.publisher.Mono;
 
 import java.util.function.Function;
diff --git a/async/async-parent/src/main/java/org/reactivecommons/async/parent/HandlerResolver.java b/async/async-parent/src/main/java/org/reactivecommons/async/parent/HandlerResolver.java
