Skip to content

Commit 5cf567e

Browse files
author
Alejandro Betancur Barrientos
committed
Refactor comunications and converters
1 parent 934f75c commit 5cf567e

File tree

60 files changed

+121
-118
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

60 files changed

+121
-118
lines changed

‎async/async-commons-standalone/src/main/java/org/reactivecommons/async/impl/config/DirectAsyncGatewayConfig.java‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,10 @@
33
import org.reactivecommons.async.impl.RabbitDirectAsyncGateway;
44
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
55
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
6-
import org.reactivecommons.async.impl.converters.MessageConverter;
6+
import org.reactivecommons.async.parent.converters.MessageConverter;
77
import org.reactivecommons.async.impl.listeners.ApplicationReplyListener;
88
import org.reactivecommons.async.impl.reply.ReactiveReplyRouter;
9+
import org.reactivecommons.async.parent.config.BrokerConfig;
910

1011
import java.nio.ByteBuffer;
1112
import java.util.Base64;

‎async/async-commons-standalone/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,9 @@
55
import lombok.extern.java.Log;
66
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
77
import org.reactivecommons.async.impl.communications.TopologyCreator;
8-
import org.reactivecommons.async.impl.converters.MessageConverter;
9-
import org.reactivecommons.async.impl.converters.json.JacksonMessageConverter;
10-
import org.reactivecommons.async.impl.converters.json.ObjectMapperSupplier;
8+
import org.reactivecommons.async.parent.converters.MessageConverter;
9+
import org.reactivecommons.async.parent.converters.json.JacksonMessageConverter;
10+
import org.reactivecommons.async.parent.converters.json.ObjectMapperSupplier;
1111
import reactor.core.publisher.Mono;
1212
import reactor.rabbitmq.*;
1313
import reactor.util.retry.Retry;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/CommandListenersConfig.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
import org.reactivecommons.async.impl.HandlerResolver;
66
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
77
import org.reactivecommons.async.impl.config.props.AsyncProps;
8-
import org.reactivecommons.async.impl.converters.MessageConverter;
9-
import org.reactivecommons.async.impl.ext.CustomErrorReporter;
8+
import org.reactivecommons.async.parent.converters.MessageConverter;
9+
import org.reactivecommons.async.parent.ext.CustomErrorReporter;
1010
import org.reactivecommons.async.impl.listeners.ApplicationCommandListener;
1111
import org.springframework.beans.factory.annotation.Value;
1212
import org.springframework.context.annotation.Bean;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/DirectAsyncGatewayConfig.java‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,9 @@
55
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
66
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
77
import org.reactivecommons.async.impl.config.props.BrokerConfigProps;
8-
import org.reactivecommons.async.impl.converters.MessageConverter;
8+
import org.reactivecommons.async.parent.converters.MessageConverter;
99
import org.reactivecommons.async.impl.listeners.ApplicationReplyListener;
10+
import org.reactivecommons.async.parent.config.BrokerConfig;
1011
import org.reactivecommons.async.parent.reply.ReactiveReplyRouter;
1112
import org.springframework.context.annotation.Bean;
1213
import org.springframework.context.annotation.Configuration;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/EventBusConfig.java‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import org.reactivecommons.async.impl.RabbitDomainEventBus;
55
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
66
import org.reactivecommons.async.impl.config.props.BrokerConfigProps;
7+
import org.reactivecommons.async.parent.config.BrokerConfig;
78
import org.springframework.context.annotation.Bean;
89
import org.springframework.context.annotation.Configuration;
910
import org.springframework.context.annotation.Import;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/EventListenersConfig.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
import org.reactivecommons.async.impl.HandlerResolver;
66
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
77
import org.reactivecommons.async.impl.config.props.AsyncProps;
8-
import org.reactivecommons.async.impl.converters.MessageConverter;
9-
import org.reactivecommons.async.impl.ext.CustomErrorReporter;
8+
import org.reactivecommons.async.parent.converters.MessageConverter;
9+
import org.reactivecommons.async.parent.ext.CustomErrorReporter;
1010
import org.reactivecommons.async.impl.listeners.ApplicationEventListener;
1111
import org.springframework.beans.factory.annotation.Value;
1212
import org.springframework.context.annotation.Bean;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/NotificacionListenersConfig.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
import org.reactivecommons.async.impl.HandlerResolver;
66
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
77
import org.reactivecommons.async.impl.config.props.AsyncProps;
8-
import org.reactivecommons.async.impl.converters.MessageConverter;
9-
import org.reactivecommons.async.impl.ext.CustomErrorReporter;
8+
import org.reactivecommons.async.parent.converters.MessageConverter;
9+
import org.reactivecommons.async.parent.ext.CustomErrorReporter;
1010
import org.reactivecommons.async.impl.listeners.ApplicationNotificationListener;
1111
import org.springframework.beans.factory.annotation.Value;
1212
import org.springframework.context.annotation.Bean;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/QueryListenerConfig.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@
66
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
77
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
88
import org.reactivecommons.async.impl.config.props.AsyncProps;
9-
import org.reactivecommons.async.impl.converters.MessageConverter;
10-
import org.reactivecommons.async.impl.ext.CustomErrorReporter;
9+
import org.reactivecommons.async.parent.converters.MessageConverter;
10+
import org.reactivecommons.async.parent.ext.CustomErrorReporter;
1111
import org.reactivecommons.async.impl.listeners.ApplicationQueryListener;
1212
import org.springframework.beans.factory.annotation.Value;
1313
import org.springframework.context.annotation.Bean;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/RabbitMqConfig.java‎

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,17 +12,19 @@
1212
import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener;
1313
import org.reactivecommons.async.api.handlers.registered.RegisteredQueryHandler;
1414
import org.reactivecommons.async.impl.*;
15-
import org.reactivecommons.async.impl.communications.Message;
15+
import org.reactivecommons.async.parent.communications.Message;
1616
import org.reactivecommons.async.impl.communications.ReactiveMessageListener;
1717
import org.reactivecommons.async.impl.communications.ReactiveMessageSender;
1818
import org.reactivecommons.async.impl.communications.TopologyCreator;
1919
import org.reactivecommons.async.impl.config.props.AsyncProps;
2020
import org.reactivecommons.async.impl.config.props.BrokerConfigProps;
21-
import org.reactivecommons.async.impl.converters.MessageConverter;
22-
import org.reactivecommons.async.impl.converters.json.DefaultObjectMapperSupplier;
23-
import org.reactivecommons.async.impl.converters.json.JacksonMessageConverter;
24-
import org.reactivecommons.async.impl.converters.json.ObjectMapperSupplier;
25-
import org.reactivecommons.async.impl.ext.CustomErrorReporter;
21+
import org.reactivecommons.async.parent.converters.MessageConverter;
22+
import org.reactivecommons.async.parent.converters.json.DefaultObjectMapperSupplier;
23+
import org.reactivecommons.async.parent.converters.json.JacksonMessageConverter;
24+
import org.reactivecommons.async.parent.converters.json.ObjectMapperSupplier;
25+
import org.reactivecommons.async.parent.ext.CustomErrorReporter;
26+
import org.reactivecommons.async.parent.config.BrokerConfig;
27+
import org.reactivecommons.async.parent.config.IBrokerConfigProps;
2628
import org.springframework.beans.factory.annotation.Value;
2729
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
2830
import org.springframework.boot.context.properties.EnableConfigurationProperties;

‎async/async-commons-starter/src/main/java/org/reactivecommons/async/impl/config/props/BrokerConfigProps.java‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,11 @@
22

33
import lombok.Getter;
44
import lombok.RequiredArgsConstructor;
5-
import org.reactivecommons.async.impl.config.IBrokerConfigProps;
5+
import org.reactivecommons.async.parent.config.IBrokerConfigProps;
66
import org.reactivecommons.async.impl.utils.NameGenerator;
77
import org.springframework.beans.factory.annotation.Value;
88
import org.springframework.context.annotation.Configuration;
9-
import org.springframework.util.Base64Utils;
109

11-
import java.nio.ByteBuffer;
12-
import java.util.UUID;
1310
import java.util.concurrent.atomic.AtomicReference;
1411

1512

0 commit comments

Comments
 (0)