Merge

Alejandro Betancur Barrientos · Alejandro Betancur Barrientos · commit 1bfe87e251cf · 2021-03-16T15:04:35.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
@@ -25,6 +25,7 @@
 import org.reactivecommons.async.parent.ext.CustomErrorReporter;
 import org.reactivecommons.async.parent.config.BrokerConfig;
 import org.reactivecommons.async.parent.config.IBrokerConfigProps;
+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/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/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.parent.communications.Message;
 import org.reactivecommons.async.parent.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.communications.Message;
 import org.reactivecommons.async.parent.converters.MessageConverter;
+import org.reactivecommons.async.parent.DiscardNotifier;
 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;
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.communications.Message;
 import org.reactivecommons.async.parent.converters.MessageConverter;
+import org.reactivecommons.async.parent.DiscardNotifier;
 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.parent.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,10 @@
 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.QueryExecutor;
 import org.reactivecommons.async.parent.communications.Message;
+import org.reactivecommons.async.parent.QueryExecutor;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
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.parent.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.parent.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.parent.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,8 +12,8 @@
 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.communications.Message;
+import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;
 import org.reactivecommons.async.parent.ext.CustomErrorReporter;
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.parent.communications.Message;
