Refactor merge

Author: andmagom

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

@@ -11,7 +11,7 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.rabbitmq.OutboundMessageResult;
-
+import static org.reactivecommons.async.parent.Headers.*;
 import java.time.Duration;
 import java.util.Collections;
 import java.util.HashMap;
@@ -20,7 +20,6 @@
 import java.util.concurrent.TimeoutException;
 
 import static java.lang.Boolean.TRUE;
-import static org.reactivecommons.async.impl.Headers.*;
 import static reactor.core.publisher.Mono.fromCallable;
 
 public class RabbitDirectAsyncGateway implements DirectAsyncGateway {

async/async-commons/src/main/java/org/reactivecommons/async/impl/DiscardNotifier.java

@@ -17,7 +17,7 @@
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Consumer;
 
-import static org.reactivecommons.async.impl.Headers.SOURCE_APPLICATION;
+import static org.reactivecommons.async.parent.Headers.SOURCE_APPLICATION;
 
 public class ReactiveMessageSender {
 

async/async-commons/src/main/java/org/reactivecommons/async/impl/EventExecutor.java

@@ -3,7 +3,7 @@
 import org.reactivecommons.async.impl.RabbitMessage;
 import org.reactivecommons.async.parent.communications.Message;
 
-import static org.reactivecommons.async.impl.Headers.*;
+import static org.reactivecommons.async.parent.Headers.*;
 
 public class TestStubs {
 

async/async-commons/src/main/java/org/reactivecommons/async/impl/QueryExecutor.java

@@ -41,7 +41,7 @@
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.mockito.ArgumentMatchers.*;
 import static org.mockito.Mockito.*;
-import static org.reactivecommons.async.impl.Headers.*;
+import static org.reactivecommons.async.parent.Headers.*;
 
 
 @ExtendWith(MockitoExtension.class)

async/async-commons/src/main/java/org/reactivecommons/async/impl/RabbitDirectAsyncGateway.java

@@ -15,7 +15,7 @@
 import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
 import org.reactivecommons.async.parent.DiscardNotifier;
 import org.reactivecommons.async.impl.HandlerResolver;
-import org.reactivecommons.async.impl.Headers;
+import org.reactivecommons.async.parent.Headers;
 import org.reactivecommons.async.parent.communications.Message;
 import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
 import org.reactivecommons.async.impl.communications.TopologyCreator;

async/async-commons/src/main/java/org/reactivecommons/async/impl/communications/ReactiveMessageSender.java

@@ -1,4 +1,4 @@
-package org.reactivecommons.async.impl;
+package org.reactivecommons.async.parent;
 
 public final class Headers {