Skip to content

Commit 32d6567

Browse files
committed
Refactor ReactiveReplyRouter
1 parent 092884e commit 32d6567

File tree

4 files changed

+4
-4
lines changed

4 files changed

+4
-4
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
88
import org.reactivecommons.async.impl.config.BrokerConfig;
99
import org.reactivecommons.async.impl.converters.MessageConverter;
10-
import org.reactivecommons.async.impl.reply.ReactiveReplyRouter;
10+
import org.reactivecommons.async.parent.reply.ReactiveReplyRouter;
1111
import reactor.core.publisher.Flux;
1212
import reactor.core.publisher.Mono;
1313
import reactor.rabbitmq.OutboundMessageResult;

async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/ApplicationReplyListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import org.reactivecommons.async.impl.RabbitMessage;
55
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
66
import org.reactivecommons.async.impl.communications.TopologyCreator;
7-
import org.reactivecommons.async.impl.reply.ReactiveReplyRouter;
7+
import org.reactivecommons.async.parent.reply.ReactiveReplyRouter;
88
import reactor.rabbitmq.Receiver;
99

1010
import java.util.logging.Level;

async/async-commons/src/test/java/org/reactivecommons/async/impl/RabbitDirectAsyncGatewayTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717
import org.reactivecommons.async.impl.converters.MessageConverter;
1818
import org.reactivecommons.async.impl.converters.json.DefaultObjectMapperSupplier;
1919
import org.reactivecommons.async.impl.converters.json.JacksonMessageConverter;
20-
import org.reactivecommons.async.impl.reply.ReactiveReplyRouter;
20+
import org.reactivecommons.async.parent.reply.ReactiveReplyRouter;
2121
import org.reactivestreams.Publisher;
2222
import reactor.core.publisher.Flux;
2323
import reactor.core.publisher.Mono;

async/async-commons/src/test/java/org/reactivecommons/async/impl/reply/ReactiveReplyRouterTest.java renamed to async/async-parent/src/test/java/org/reactivecommons/async/parent/reply/ReactiveReplyRouterTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package org.reactivecommons.async.impl.reply;
1+
package org.reactivecommons.async.parent.reply;
22

33
import org.junit.jupiter.api.Test;
44
import org.mockito.Mockito;

0 commit comments

Comments
 (0)