From 9b30cf855803337dcd4793bd1eaae2907ae6c927 Mon Sep 17 00:00:00 2001 From: JuanC Galvis <8420868+juancgalvis@users.noreply.github.com> Date: Thu, 9 Jan 2025 14:38:33 -0500 Subject: [PATCH] fix(dynamic-registry): move to respective listener bean dependency (#130) * fix(error-reporter): Restore CustomReporter to default rabbit config * fix(imports): Optimize imports --- .../test/DirectGatewayPerfTest.java | 2 +- .../reactivecommons/test/DummyMessage.java | 1 + .../test/DynamicRegistryTest.java | 1 - .../test/SimpleDirectCommunicationTest.java | 4 +-- .../test/SimpleEventNotificationTest.java | 5 ++-- .../perf/BlockingCommandHandlePerfTest.java | 3 +- ...allelOnBlockingInSubscriptionTimeTest.java | 1 - .../perf/SimpleCommandHandlePerfTest.java | 1 - .../async/api/DynamicRegistry.java | 1 - .../json/JacksonMessageConverter.java | 1 - .../commons/utils/NameGeneratorTest.java | 4 ++- .../KeyMatcherPerformanceManualTest.java | 7 ++++- .../ApplicationNotificationsListener.java | 1 - .../topology/KafkaCustomizationsTest.java | 2 -- .../listeners/GenericMessageListenerTest.java | 2 -- .../async/rabbit/DynamicRegistryImp.java | 4 +-- .../listeners/ApplicationCommandListener.java | 2 +- .../async/helpers/TestStubs.java | 6 ++-- .../async/rabbit/DynamicRegistryImpTest.java | 5 +++- .../async/rabbit/QueryExecutorTest.java | 4 +-- .../async/rabbit/RabbitMessageTest.java | 1 - .../GenericMessageListenerPerfTest.java | 23 +++++++++++++-- .../java/sample/SampleRestController.java | 2 -- .../src/main/java/sample/HandlersConfig.java | 1 - .../java/sample/SampleRestController.java | 3 -- .../starter/config/ReactiveCommonsConfig.java | 10 ++++++- .../ReactiveCommonsListenersConfig.java | 10 ++----- .../listeners/EventsListenerConfig.java | 2 +- .../NotificationEventsListenerConfig.java | 2 +- .../mybroker/MyBrokerSecretFiller.java | 2 +- .../props/MyBrokerAsyncPropsDomain.java | 2 +- .../{ => common}/kafka/RCKafkaConfig.java | 2 +- .../KafkaReactiveHealthIndicatorTest.java | 3 -- .../kafka}/KafkaConfigTest.java | 3 +- .../config/RabbitPropertiesAutoConfig.java | 1 - .../{ => common}/rabbit/RabbitMQConfig.java | 24 ++------------- .../rabbit/RabbitMQListenerOnlyConfig.java | 29 +++++++++++++++++++ .../rabbit/RabbitMQConfigTest.java | 2 +- 38 files changed, 100 insertions(+), 79 deletions(-) rename starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/{ => common}/kafka/RCKafkaConfig.java (97%) rename starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/{rabbit => common/kafka}/KafkaConfigTest.java (92%) rename starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/{ => common}/rabbit/RabbitMQConfig.java (60%) create mode 100644 starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/listener/rabbit/RabbitMQListenerOnlyConfig.java rename starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/{ => common}/rabbit/RabbitMQConfigTest.java (95%) diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/DirectGatewayPerfTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/DirectGatewayPerfTest.java index b312eef5..0e4ade8c 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/DirectGatewayPerfTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/DirectGatewayPerfTest.java @@ -3,8 +3,8 @@ import org.assertj.core.api.Assertions; import org.junit.jupiter.api.Test; import org.reactivecommons.api.domain.Command; -import org.reactivecommons.async.rabbit.RabbitDirectAsyncGateway; import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway; +import org.reactivecommons.async.rabbit.RabbitDirectAsyncGateway; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.SpringApplication; diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/DummyMessage.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/DummyMessage.java index a36f3cff..d2445516 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/DummyMessage.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/DummyMessage.java @@ -1,6 +1,7 @@ package org.reactivecommons.test; import lombok.Data; + import java.util.concurrent.ThreadLocalRandom; @Data diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/DynamicRegistryTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/DynamicRegistryTest.java index cb56377a..d5a94a4e 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/DynamicRegistryTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/DynamicRegistryTest.java @@ -5,7 +5,6 @@ import org.reactivecommons.api.domain.DomainEventBus; import org.reactivecommons.async.api.DynamicRegistry; import org.reactivecommons.async.api.handlers.DomainEventHandler; -import org.reactivecommons.async.api.handlers.EventHandler; import org.reactivecommons.async.impl.config.annotations.EnableDomainEventBus; import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners; import org.reactivestreams.Publisher; diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleDirectCommunicationTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleDirectCommunicationTest.java index d8e26034..d8aa74cf 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleDirectCommunicationTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleDirectCommunicationTest.java @@ -5,7 +5,6 @@ import org.reactivecommons.async.api.AsyncQuery; import org.reactivecommons.async.api.DirectAsyncGateway; import org.reactivecommons.async.api.HandlerRegistry; -import org.reactivecommons.async.api.handlers.CommandHandler; import org.reactivecommons.async.api.handlers.DomainCommandHandler; import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway; import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners; @@ -23,7 +22,8 @@ import java.util.concurrent.ThreadLocalRandom; import static org.assertj.core.api.Assertions.assertThat; -import static reactor.core.publisher.Mono.*; +import static reactor.core.publisher.Mono.empty; +import static reactor.core.publisher.Mono.just; @SpringBootTest class SimpleDirectCommunicationTest { diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleEventNotificationTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleEventNotificationTest.java index e700f1ab..e8c8c313 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleEventNotificationTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/SimpleEventNotificationTest.java @@ -5,7 +5,6 @@ import org.reactivecommons.api.domain.DomainEventBus; import org.reactivecommons.async.api.HandlerRegistry; import org.reactivecommons.async.api.handlers.DomainEventHandler; -import org.reactivecommons.async.api.handlers.EventHandler; import org.reactivecommons.async.impl.config.annotations.EnableDomainEventBus; import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners; import org.springframework.beans.factory.annotation.Autowired; @@ -19,7 +18,9 @@ import java.util.concurrent.ThreadLocalRandom; import static org.assertj.core.api.Assertions.assertThat; -import static reactor.core.publisher.Mono.*; +import static reactor.core.publisher.Mono.empty; +import static reactor.core.publisher.Mono.from; +import static reactor.core.publisher.Mono.just; @SpringBootTest class SimpleEventNotificationTest { diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java index aa602602..df853929 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/BlockingCommandHandlePerfTest.java @@ -4,7 +4,6 @@ import org.reactivecommons.api.domain.Command; import org.reactivecommons.async.api.DirectAsyncGateway; import org.reactivecommons.async.api.HandlerRegistry; -import org.reactivecommons.async.api.handlers.CommandHandler; import org.reactivecommons.async.api.handlers.DomainCommandHandler; import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway; import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners; @@ -24,7 +23,7 @@ import static java.lang.System.out; import static org.assertj.core.api.Assertions.assertThat; -import static reactor.core.publisher.Mono.*; +import static reactor.core.publisher.Mono.fromRunnable; @SpringBootTest class BlockingCommandHandlePerfTest { diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/ParallelOnBlockingInSubscriptionTimeTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/ParallelOnBlockingInSubscriptionTimeTest.java index 5d578c1a..510c38f6 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/ParallelOnBlockingInSubscriptionTimeTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/ParallelOnBlockingInSubscriptionTimeTest.java @@ -5,7 +5,6 @@ import org.reactivecommons.api.domain.Command; import org.reactivecommons.async.api.DirectAsyncGateway; import org.reactivecommons.async.api.HandlerRegistry; -import org.reactivecommons.async.api.handlers.CommandHandler; import org.reactivecommons.async.api.handlers.DomainCommandHandler; import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway; import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners; diff --git a/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/SimpleCommandHandlePerfTest.java b/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/SimpleCommandHandlePerfTest.java index fc9b4f50..f5c37146 100644 --- a/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/SimpleCommandHandlePerfTest.java +++ b/acceptance/async-tests/src/test/java/org/reactivecommons/test/perf/SimpleCommandHandlePerfTest.java @@ -5,7 +5,6 @@ import org.reactivecommons.api.domain.Command; import org.reactivecommons.async.api.DirectAsyncGateway; import org.reactivecommons.async.api.HandlerRegistry; -import org.reactivecommons.async.api.handlers.CommandHandler; import org.reactivecommons.async.api.handlers.DomainCommandHandler; import org.reactivecommons.async.impl.config.annotations.EnableDirectAsyncGateway; import org.reactivecommons.async.impl.config.annotations.EnableMessageListeners; diff --git a/async/async-commons-api/src/main/java/org/reactivecommons/async/api/DynamicRegistry.java b/async/async-commons-api/src/main/java/org/reactivecommons/async/api/DynamicRegistry.java index 39ebe722..e24de8d3 100644 --- a/async/async-commons-api/src/main/java/org/reactivecommons/async/api/DynamicRegistry.java +++ b/async/async-commons-api/src/main/java/org/reactivecommons/async/api/DynamicRegistry.java @@ -1,7 +1,6 @@ package org.reactivecommons.async.api; import org.reactivecommons.async.api.handlers.DomainEventHandler; -import org.reactivecommons.async.api.handlers.EventHandler; import org.reactivecommons.async.api.handlers.QueryHandler; import org.reactivecommons.async.api.handlers.QueryHandlerDelegate; import reactor.core.publisher.Mono; diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/commons/converters/json/JacksonMessageConverter.java b/async/async-commons/src/main/java/org/reactivecommons/async/commons/converters/json/JacksonMessageConverter.java index 5d0cbd70..92e8bc72 100644 --- a/async/async-commons/src/main/java/org/reactivecommons/async/commons/converters/json/JacksonMessageConverter.java +++ b/async/async-commons/src/main/java/org/reactivecommons/async/commons/converters/json/JacksonMessageConverter.java @@ -3,7 +3,6 @@ import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import io.cloudevents.CloudEvent; -import io.cloudevents.jackson.JsonFormat; import lombok.Data; import lombok.RequiredArgsConstructor; import org.reactivecommons.api.domain.Command; diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/NameGeneratorTest.java b/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/NameGeneratorTest.java index 47b373c5..8a19553d 100644 --- a/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/NameGeneratorTest.java +++ b/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/NameGeneratorTest.java @@ -2,7 +2,9 @@ import org.junit.jupiter.api.Test; -import static org.junit.jupiter.api.Assertions.*; +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertFalse; +import static org.junit.jupiter.api.Assertions.assertTrue; class NameGeneratorTest { diff --git a/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/matcher/KeyMatcherPerformanceManualTest.java b/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/matcher/KeyMatcherPerformanceManualTest.java index d93d069b..c07c9ea9 100755 --- a/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/matcher/KeyMatcherPerformanceManualTest.java +++ b/async/async-commons/src/test/java/org/reactivecommons/async/commons/utils/matcher/KeyMatcherPerformanceManualTest.java @@ -8,7 +8,12 @@ import java.io.IOException; import java.nio.file.Files; import java.nio.file.Paths; -import java.util.*; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Set; import java.util.stream.Collectors; class KeyMatcherPerformanceManualTest { diff --git a/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationNotificationsListener.java b/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationNotificationsListener.java index 9758462f..2b0170e8 100644 --- a/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationNotificationsListener.java +++ b/async/async-kafka/src/main/java/org/reactivecommons/async/kafka/listeners/ApplicationNotificationsListener.java @@ -14,7 +14,6 @@ import reactor.core.publisher.Mono; import reactor.kafka.receiver.ReceiverRecord; -import java.util.Optional; import java.util.UUID; import java.util.function.Function; diff --git a/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/communications/topology/KafkaCustomizationsTest.java b/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/communications/topology/KafkaCustomizationsTest.java index 6b5b035e..2f8dcb41 100644 --- a/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/communications/topology/KafkaCustomizationsTest.java +++ b/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/communications/topology/KafkaCustomizationsTest.java @@ -2,8 +2,6 @@ import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; -import org.reactivecommons.async.kafka.communications.topology.KafkaCustomizations; -import org.reactivecommons.async.kafka.communications.topology.TopicCustomization; import java.util.HashMap; import java.util.Map; diff --git a/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/listeners/GenericMessageListenerTest.java b/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/listeners/GenericMessageListenerTest.java index 1025ad60..83dbdeb9 100644 --- a/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/listeners/GenericMessageListenerTest.java +++ b/async/async-kafka/src/test/java/org/reactivecommons/async/kafka/listeners/GenericMessageListenerTest.java @@ -15,7 +15,6 @@ import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.core.publisher.MonoSink; -import reactor.kafka.receiver.ReceiverOffset; import reactor.kafka.receiver.ReceiverRecord; import reactor.test.StepVerifier; @@ -26,7 +25,6 @@ import static org.mockito.ArgumentMatchers.any; import static org.mockito.ArgumentMatchers.anyString; -import static org.mockito.Mockito.atLeastOnce; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.times; import static org.mockito.Mockito.verify; diff --git a/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/DynamicRegistryImp.java b/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/DynamicRegistryImp.java index 608cc099..8e22c31a 100644 --- a/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/DynamicRegistryImp.java +++ b/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/DynamicRegistryImp.java @@ -4,7 +4,6 @@ import lombok.RequiredArgsConstructor; import org.reactivecommons.async.api.DynamicRegistry; import org.reactivecommons.async.api.handlers.DomainEventHandler; -import org.reactivecommons.async.api.handlers.EventHandler; import org.reactivecommons.async.api.handlers.QueryHandler; import org.reactivecommons.async.api.handlers.QueryHandlerDelegate; import org.reactivecommons.async.api.handlers.registered.RegisteredEventListener; @@ -33,7 +32,8 @@ public Mono listenEvent(String eventName, DomainEventHandler fn, Cl @Override public void serveQuery(String resource, QueryHandler handler, Class queryClass) { - resolver.addQueryHandler(new RegisteredQueryHandler<>(resource, (ignored, message) -> handler.handle(message), queryClass)); + resolver.addQueryHandler(new RegisteredQueryHandler<>(resource, (ignored, message) -> handler.handle(message) + , queryClass)); } @Override diff --git a/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/listeners/ApplicationCommandListener.java b/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/listeners/ApplicationCommandListener.java index 70af3dc3..2e04b22f 100644 --- a/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/listeners/ApplicationCommandListener.java +++ b/async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/listeners/ApplicationCommandListener.java @@ -8,10 +8,10 @@ import org.reactivecommons.async.api.handlers.registered.RegisteredCommandHandler; import org.reactivecommons.async.commons.CommandExecutor; import org.reactivecommons.async.commons.DiscardNotifier; +import org.reactivecommons.async.commons.HandlerResolver; import org.reactivecommons.async.commons.communications.Message; import org.reactivecommons.async.commons.converters.MessageConverter; import org.reactivecommons.async.commons.ext.CustomReporter; -import org.reactivecommons.async.commons.HandlerResolver; import org.reactivecommons.async.rabbit.RabbitMessage; import org.reactivecommons.async.rabbit.communications.ReactiveMessageListener; import org.reactivecommons.async.rabbit.communications.TopologyCreator; diff --git a/async/async-rabbit/src/test/java/org/reactivecommons/async/helpers/TestStubs.java b/async/async-rabbit/src/test/java/org/reactivecommons/async/helpers/TestStubs.java index 028b0b88..6736ed1a 100644 --- a/async/async-rabbit/src/test/java/org/reactivecommons/async/helpers/TestStubs.java +++ b/async/async-rabbit/src/test/java/org/reactivecommons/async/helpers/TestStubs.java @@ -1,9 +1,11 @@ package org.reactivecommons.async.helpers; -import org.reactivecommons.async.rabbit.RabbitMessage; import org.reactivecommons.async.commons.communications.Message; +import org.reactivecommons.async.rabbit.RabbitMessage; -import static org.reactivecommons.async.commons.Headers.*; +import static org.reactivecommons.async.commons.Headers.CORRELATION_ID; +import static org.reactivecommons.async.commons.Headers.REPLY_ID; +import static org.reactivecommons.async.commons.Headers.SERVED_QUERY_ID; public class TestStubs { diff --git a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/DynamicRegistryImpTest.java b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/DynamicRegistryImpTest.java index 4ae881eb..111c63c6 100644 --- a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/DynamicRegistryImpTest.java +++ b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/DynamicRegistryImpTest.java @@ -23,7 +23,10 @@ import java.util.concurrent.ConcurrentHashMap; import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.Mockito.*; +import static org.mockito.Mockito.any; +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; import static reactor.core.publisher.Mono.just; diff --git a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/QueryExecutorTest.java b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/QueryExecutorTest.java index 0324dc06..777f43aa 100644 --- a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/QueryExecutorTest.java +++ b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/QueryExecutorTest.java @@ -8,10 +8,10 @@ import org.mockito.junit.jupiter.MockitoExtension; import org.reactivecommons.async.api.From; import org.reactivecommons.async.api.handlers.QueryHandlerDelegate; +import org.reactivecommons.async.commons.QueryExecutor; +import org.reactivecommons.async.commons.communications.Message; import org.reactivecommons.async.helpers.SampleClass; import org.reactivecommons.async.helpers.TestStubs; -import org.reactivecommons.async.commons.communications.Message; -import org.reactivecommons.async.commons.QueryExecutor; import reactor.core.publisher.Mono; import reactor.test.StepVerifier; diff --git a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/RabbitMessageTest.java b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/RabbitMessageTest.java index c7b48327..536cb968 100644 --- a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/RabbitMessageTest.java +++ b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/RabbitMessageTest.java @@ -4,7 +4,6 @@ import com.rabbitmq.client.Delivery; import com.rabbitmq.client.Envelope; import org.junit.jupiter.api.Test; -import org.reactivecommons.async.rabbit.RabbitMessage; import java.util.HashMap; import java.util.Map; diff --git a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/listeners/GenericMessageListenerPerfTest.java b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/listeners/GenericMessageListenerPerfTest.java index 7f0f40c4..f7dd0377 100644 --- a/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/listeners/GenericMessageListenerPerfTest.java +++ b/async/async-rabbit/src/test/java/org/reactivecommons/async/rabbit/listeners/GenericMessageListenerPerfTest.java @@ -2,7 +2,24 @@ import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; -import com.rabbitmq.client.*; +import com.rabbitmq.client.AMQP; +import com.rabbitmq.client.BuiltinExchangeType; +import com.rabbitmq.client.CancelCallback; +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.ConfirmCallback; +import com.rabbitmq.client.ConfirmListener; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.Consumer; +import com.rabbitmq.client.ConsumerShutdownSignalCallback; +import com.rabbitmq.client.DeliverCallback; +import com.rabbitmq.client.Delivery; +import com.rabbitmq.client.Envelope; +import com.rabbitmq.client.GetResponse; +import com.rabbitmq.client.Method; +import com.rabbitmq.client.ReturnCallback; +import com.rabbitmq.client.ReturnListener; +import com.rabbitmq.client.ShutdownListener; +import com.rabbitmq.client.ShutdownSignalException; import lombok.Data; import org.assertj.core.api.Assertions; import org.junit.jupiter.api.BeforeEach; @@ -12,11 +29,11 @@ import org.mockito.Mockito; import org.mockito.junit.jupiter.MockitoExtension; import org.reactivecommons.api.domain.Command; -import org.reactivecommons.async.commons.communications.Message; import org.reactivecommons.async.commons.DiscardNotifier; +import org.reactivecommons.async.commons.communications.Message; +import org.reactivecommons.async.commons.ext.CustomReporter; import org.reactivecommons.async.rabbit.communications.ReactiveMessageListener; import org.reactivecommons.async.rabbit.communications.TopologyCreator; -import org.reactivecommons.async.commons.ext.CustomReporter; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import reactor.rabbitmq.AcknowledgableDelivery; diff --git a/samples/async/async-kafka-sender-client/src/main/java/sample/SampleRestController.java b/samples/async/async-kafka-sender-client/src/main/java/sample/SampleRestController.java index 98cf4009..27c11203 100644 --- a/samples/async/async-kafka-sender-client/src/main/java/sample/SampleRestController.java +++ b/samples/async/async-kafka-sender-client/src/main/java/sample/SampleRestController.java @@ -2,14 +2,12 @@ import com.fasterxml.jackson.core.JsonProcessingException; import io.cloudevents.CloudEvent; -import io.cloudevents.CloudEventData; import io.cloudevents.core.builder.CloudEventBuilder; import io.cloudevents.jackson.JsonCloudEventData; import lombok.Data; import lombok.RequiredArgsConstructor; import org.reactivecommons.api.domain.DomainEvent; import org.reactivecommons.api.domain.DomainEventBus; -import org.reactivecommons.async.commons.converters.json.CloudEventBuilderExt; import org.reactivecommons.async.commons.converters.json.ObjectMapperSupplier; import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.RestController; diff --git a/samples/async/async-receiver-responder/src/main/java/sample/HandlersConfig.java b/samples/async/async-receiver-responder/src/main/java/sample/HandlersConfig.java index 5f4807dd..75f79669 100644 --- a/samples/async/async-receiver-responder/src/main/java/sample/HandlersConfig.java +++ b/samples/async/async-receiver-responder/src/main/java/sample/HandlersConfig.java @@ -4,7 +4,6 @@ import org.reactivecommons.async.api.DynamicRegistry; import org.reactivecommons.async.api.HandlerRegistry; import org.reactivecommons.async.api.handlers.DomainEventHandler; -import org.reactivecommons.async.api.handlers.EventHandler; import org.springframework.boot.CommandLineRunner; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; diff --git a/samples/async/async-sender-client/src/main/java/sample/SampleRestController.java b/samples/async/async-sender-client/src/main/java/sample/SampleRestController.java index a2087551..00e060c3 100644 --- a/samples/async/async-sender-client/src/main/java/sample/SampleRestController.java +++ b/samples/async/async-sender-client/src/main/java/sample/SampleRestController.java @@ -1,6 +1,5 @@ package sample; -import io.cloudevents.CloudEvent; import lombok.RequiredArgsConstructor; import org.reactivecommons.api.domain.Command; import org.reactivecommons.api.domain.DomainEvent; @@ -23,8 +22,6 @@ import sample.model.broker.AnimalEvent; import sample.model.broker.RemovedMemberEvent; -import java.net.URI; -import java.time.OffsetDateTime; import java.util.UUID; import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE; diff --git a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsConfig.java b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsConfig.java index 1b612fdc..fdb02d8d 100644 --- a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsConfig.java +++ b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsConfig.java @@ -8,6 +8,8 @@ import org.reactivecommons.async.commons.config.BrokerConfig; import org.reactivecommons.async.commons.converters.json.DefaultObjectMapperSupplier; import org.reactivecommons.async.commons.converters.json.ObjectMapperSupplier; +import org.reactivecommons.async.commons.ext.CustomReporter; +import org.reactivecommons.async.commons.ext.DefaultCustomReporter; import org.reactivecommons.async.commons.reply.ReactiveReplyRouter; import org.reactivecommons.async.starter.broker.BrokerProvider; import org.reactivecommons.async.starter.broker.BrokerProviderFactory; @@ -30,7 +32,7 @@ @Configuration @RequiredArgsConstructor @Import(ReactiveCommonsHealthConfig.class) -@ComponentScan("org.reactivecommons.async.starter.impl") +@ComponentScan("org.reactivecommons.async.starter.impl.common") public class ReactiveCommonsConfig { @Bean @@ -89,4 +91,10 @@ public MeterRegistry defaultRabbitMeterRegistry() { return new SimpleMeterRegistry(); } + @Bean + @ConditionalOnMissingBean + public CustomReporter reactiveCommonsCustomErrorReporter() { + return new DefaultCustomReporter(); + } + } diff --git a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsListenersConfig.java b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsListenersConfig.java index 96bdc138..44cc8772 100644 --- a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsListenersConfig.java +++ b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsListenersConfig.java @@ -7,12 +7,11 @@ import org.reactivecommons.async.api.HandlerRegistry; import org.reactivecommons.async.commons.HandlerResolver; import org.reactivecommons.async.commons.HandlerResolverBuilder; -import org.reactivecommons.async.commons.ext.CustomReporter; -import org.reactivecommons.async.commons.ext.DefaultCustomReporter; import org.reactivecommons.async.starter.props.GenericAsyncPropsDomain; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import reactor.core.publisher.Mono; @@ -21,6 +20,7 @@ @Log @Configuration @RequiredArgsConstructor +@ComponentScan("org.reactivecommons.async.starter.impl.listener") public class ReactiveCommonsListenersConfig { @Bean @@ -41,12 +41,6 @@ public DomainHandlers buildHandlers(ApplicationContext context, return handlers; } - @Bean - @ConditionalOnMissingBean - public CustomReporter reactiveCommonsCustomErrorReporter() { - return new DefaultCustomReporter(); - } - @Bean @ConditionalOnMissingBean @SuppressWarnings("rawtypes") diff --git a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/EventsListenerConfig.java b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/EventsListenerConfig.java index 6e465f84..3e31d9fa 100644 --- a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/EventsListenerConfig.java +++ b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/EventsListenerConfig.java @@ -2,8 +2,8 @@ import org.reactivecommons.async.commons.HandlerResolver; -import org.reactivecommons.async.starter.config.ConnectionManager; import org.reactivecommons.async.starter.broker.BrokerProvider; +import org.reactivecommons.async.starter.config.ConnectionManager; import org.reactivecommons.async.starter.config.DomainHandlers; import org.reactivecommons.async.starter.config.ReactiveCommonsConfig; import org.reactivecommons.async.starter.config.ReactiveCommonsListenersConfig; diff --git a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/NotificationEventsListenerConfig.java b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/NotificationEventsListenerConfig.java index cae527fe..8e918915 100644 --- a/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/NotificationEventsListenerConfig.java +++ b/starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/listeners/NotificationEventsListenerConfig.java @@ -2,8 +2,8 @@ import org.reactivecommons.async.commons.HandlerResolver; -import org.reactivecommons.async.starter.config.ConnectionManager; import org.reactivecommons.async.starter.broker.BrokerProvider; +import org.reactivecommons.async.starter.config.ConnectionManager; import org.reactivecommons.async.starter.config.DomainHandlers; import org.reactivecommons.async.starter.config.ReactiveCommonsConfig; import org.reactivecommons.async.starter.config.ReactiveCommonsListenersConfig; diff --git a/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/MyBrokerSecretFiller.java b/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/MyBrokerSecretFiller.java index 2af3a2e8..29a8a841 100644 --- a/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/MyBrokerSecretFiller.java +++ b/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/MyBrokerSecretFiller.java @@ -1,7 +1,7 @@ package org.reactivecommons.async.starter.mybroker; -import org.reactivecommons.async.starter.props.GenericAsyncPropsDomain; import org.reactivecommons.async.starter.mybroker.props.MyBrokerConnProps; +import org.reactivecommons.async.starter.props.GenericAsyncPropsDomain; public interface MyBrokerSecretFiller extends GenericAsyncPropsDomain.SecretFiller { } \ No newline at end of file diff --git a/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/props/MyBrokerAsyncPropsDomain.java b/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/props/MyBrokerAsyncPropsDomain.java index d2239eb0..fa348806 100644 --- a/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/props/MyBrokerAsyncPropsDomain.java +++ b/starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/props/MyBrokerAsyncPropsDomain.java @@ -2,8 +2,8 @@ import lombok.Getter; import lombok.Setter; -import org.reactivecommons.async.starter.props.GenericAsyncPropsDomain; import org.reactivecommons.async.starter.mybroker.MyBrokerSecretFiller; +import org.reactivecommons.async.starter.props.GenericAsyncPropsDomain; import org.springframework.beans.factory.annotation.Value; @Getter diff --git a/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/kafka/RCKafkaConfig.java b/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/common/kafka/RCKafkaConfig.java similarity index 97% rename from starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/kafka/RCKafkaConfig.java rename to starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/common/kafka/RCKafkaConfig.java index 3b830911..e0749722 100644 --- a/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/kafka/RCKafkaConfig.java +++ b/starters/async-kafka-starter/src/main/java/org/reactivecommons/async/starter/impl/common/kafka/RCKafkaConfig.java @@ -1,4 +1,4 @@ -package org.reactivecommons.async.starter.impl.kafka; +package org.reactivecommons.async.starter.impl.common.kafka; import org.reactivecommons.async.commons.converters.json.ObjectMapperSupplier; import org.reactivecommons.async.kafka.KafkaBrokerProviderFactory; diff --git a/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/kafka/health/KafkaReactiveHealthIndicatorTest.java b/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/kafka/health/KafkaReactiveHealthIndicatorTest.java index 132bd660..b713a513 100644 --- a/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/kafka/health/KafkaReactiveHealthIndicatorTest.java +++ b/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/kafka/health/KafkaReactiveHealthIndicatorTest.java @@ -10,9 +10,6 @@ import org.mockito.Mock; import org.mockito.junit.jupiter.MockitoExtension; import org.reactivecommons.async.starter.config.health.RCHealth; -import org.springframework.boot.actuate.health.Health; -import org.springframework.boot.actuate.health.Health.Builder; -import org.springframework.boot.actuate.health.Status; import reactor.core.publisher.Mono; import reactor.test.StepVerifier; diff --git a/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/KafkaConfigTest.java b/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/common/kafka/KafkaConfigTest.java similarity index 92% rename from starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/KafkaConfigTest.java rename to starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/common/kafka/KafkaConfigTest.java index 9fb2ddb4..25363d28 100644 --- a/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/KafkaConfigTest.java +++ b/starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/common/kafka/KafkaConfigTest.java @@ -1,4 +1,4 @@ -package org.reactivecommons.async.starter.impl.rabbit; +package org.reactivecommons.async.starter.impl.common.kafka; import org.junit.jupiter.api.Test; @@ -8,7 +8,6 @@ import org.reactivecommons.async.starter.config.ConnectionManager; import org.reactivecommons.async.starter.config.ReactiveCommonsConfig; import org.reactivecommons.async.starter.config.ReactiveCommonsListenersConfig; -import org.reactivecommons.async.starter.impl.kafka.RCKafkaConfig; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; diff --git a/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/rabbit/config/RabbitPropertiesAutoConfig.java b/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/rabbit/config/RabbitPropertiesAutoConfig.java index e05cd797..399b6c20 100644 --- a/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/rabbit/config/RabbitPropertiesAutoConfig.java +++ b/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/rabbit/config/RabbitPropertiesAutoConfig.java @@ -2,7 +2,6 @@ import org.reactivecommons.async.rabbit.config.spring.RabbitPropertiesBase; import org.springframework.boot.context.properties.ConfigurationProperties; -import org.springframework.context.annotation.Primary; @ConfigurationProperties(prefix = "spring.rabbitmq") public class RabbitPropertiesAutoConfig extends RabbitPropertiesBase { diff --git a/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfig.java b/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/common/rabbit/RabbitMQConfig.java similarity index 60% rename from starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfig.java rename to starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/common/rabbit/RabbitMQConfig.java index 50526cb3..1345923e 100644 --- a/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfig.java +++ b/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/common/rabbit/RabbitMQConfig.java @@ -1,30 +1,20 @@ -package org.reactivecommons.async.starter.impl.rabbit; +package org.reactivecommons.async.starter.impl.common.rabbit; import lombok.RequiredArgsConstructor; import lombok.extern.java.Log; -import org.reactivecommons.async.api.DynamicRegistry; -import org.reactivecommons.async.commons.config.IBrokerConfigProps; import org.reactivecommons.async.commons.converters.json.ObjectMapperSupplier; -import org.reactivecommons.async.rabbit.DynamicRegistryImp; import org.reactivecommons.async.rabbit.RabbitMQBrokerProviderFactory; -import org.reactivecommons.async.rabbit.RabbitMQSetupUtils; -import org.reactivecommons.async.rabbit.communications.TopologyCreator; import org.reactivecommons.async.rabbit.config.RabbitProperties; import org.reactivecommons.async.rabbit.config.RabbitPropertiesAutoConfig; -import org.reactivecommons.async.rabbit.config.props.AsyncProps; import org.reactivecommons.async.rabbit.config.props.AsyncPropsDomain; import org.reactivecommons.async.rabbit.config.props.AsyncRabbitPropsDomainProperties; -import org.reactivecommons.async.rabbit.config.props.BrokerConfigProps; import org.reactivecommons.async.rabbit.converters.json.RabbitJacksonMessageConverter; -import org.reactivecommons.async.starter.config.DomainHandlers; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Import; -import static org.reactivecommons.async.api.HandlerRegistry.DEFAULT_DOMAIN; - @Log @Configuration @RequiredArgsConstructor @@ -38,15 +28,6 @@ public RabbitJacksonMessageConverter messageConverter(ObjectMapperSupplier objec return new RabbitJacksonMessageConverter(objectMapperSupplier.get()); } - @Bean - @ConditionalOnMissingBean(DynamicRegistry.class) - public DynamicRegistry dynamicRegistry(AsyncPropsDomain asyncPropsDomain, DomainHandlers handlers) { - AsyncProps props = asyncPropsDomain.getProps(DEFAULT_DOMAIN); - TopologyCreator topologyCreator = RabbitMQSetupUtils.createTopologyCreator(props); - IBrokerConfigProps brokerConfigProps = new BrokerConfigProps(asyncPropsDomain.getProps(DEFAULT_DOMAIN)); - return new DynamicRegistryImp(handlers.get(DEFAULT_DOMAIN), topologyCreator, brokerConfigProps); - } - @Bean @ConditionalOnMissingBean(AsyncPropsDomain.RabbitSecretFiller.class) public AsyncPropsDomain.RabbitSecretFiller defaultRabbitSecretFiller() { @@ -56,7 +37,8 @@ public AsyncPropsDomain.RabbitSecretFiller defaultRabbitSecretFiller() { @Bean @ConditionalOnMissingBean(RabbitProperties.class) - public RabbitProperties defaultRabbitProperties(RabbitPropertiesAutoConfig properties, ObjectMapperSupplier supplier) { + public RabbitProperties defaultRabbitProperties(RabbitPropertiesAutoConfig properties, + ObjectMapperSupplier supplier) { return supplier.get().convertValue(properties, RabbitProperties.class); } diff --git a/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/listener/rabbit/RabbitMQListenerOnlyConfig.java b/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/listener/rabbit/RabbitMQListenerOnlyConfig.java new file mode 100644 index 00000000..cebe207e --- /dev/null +++ b/starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/starter/impl/listener/rabbit/RabbitMQListenerOnlyConfig.java @@ -0,0 +1,29 @@ +package org.reactivecommons.async.starter.impl.listener.rabbit; + +import org.reactivecommons.async.api.DynamicRegistry; +import org.reactivecommons.async.commons.config.IBrokerConfigProps; +import org.reactivecommons.async.rabbit.DynamicRegistryImp; +import org.reactivecommons.async.rabbit.RabbitMQSetupUtils; +import org.reactivecommons.async.rabbit.communications.TopologyCreator; +import org.reactivecommons.async.rabbit.config.props.AsyncProps; +import org.reactivecommons.async.rabbit.config.props.AsyncPropsDomain; +import org.reactivecommons.async.rabbit.config.props.BrokerConfigProps; +import org.reactivecommons.async.starter.config.DomainHandlers; +import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import static org.reactivecommons.async.api.HandlerRegistry.DEFAULT_DOMAIN; + +@Configuration +public class RabbitMQListenerOnlyConfig { + + @Bean + @ConditionalOnMissingBean(DynamicRegistry.class) + public DynamicRegistry dynamicRegistry(AsyncPropsDomain asyncPropsDomain, DomainHandlers handlers) { + AsyncProps props = asyncPropsDomain.getProps(DEFAULT_DOMAIN); + TopologyCreator topologyCreator = RabbitMQSetupUtils.createTopologyCreator(props); + IBrokerConfigProps brokerConfigProps = new BrokerConfigProps(asyncPropsDomain.getProps(DEFAULT_DOMAIN)); + return new DynamicRegistryImp(handlers.get(DEFAULT_DOMAIN), topologyCreator, brokerConfigProps); + } +} diff --git a/starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfigTest.java b/starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/common/rabbit/RabbitMQConfigTest.java similarity index 95% rename from starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfigTest.java rename to starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/common/rabbit/RabbitMQConfigTest.java index f811c68d..29b0f364 100644 --- a/starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfigTest.java +++ b/starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/common/rabbit/RabbitMQConfigTest.java @@ -1,4 +1,4 @@ -package org.reactivecommons.async.starter.impl.rabbit; +package org.reactivecommons.async.starter.impl.common.rabbit; import org.junit.jupiter.api.Test; import org.reactivecommons.async.rabbit.RabbitMQBrokerProviderFactory;