fix(test): Fix unit tests and update gradle

Author: juancgalvis

build.gradle

@@ -15,7 +15,7 @@ plugins {
     id 'org.sonarqube' version '6.0.1.5171'
     id 'org.springframework.boot' version '3.4.1' apply false
     id 'io.github.gradle-nexus.publish-plugin' version '2.0.0'
-    id 'co.com.bancolombia.cleanArchitecture' version '3.20.7'
+    id 'co.com.bancolombia.cleanArchitecture' version '3.20.8'
 }
 
 repositories {

gradle/wrapper/gradle-wrapper.properties

@@ -1,6 +1,6 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-8.10.2-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.11.1-bin.zip
 networkTimeout=10000
 validateDistributionUrl=true
 zipStoreBase=GRADLE_USER_HOME

main.gradle

@@ -176,5 +176,5 @@ tasks.register('generateMergedReport', JacocoReport) {
 }
 
 tasks.named('wrapper') {
-    gradleVersion = '8.11'
+    gradleVersion = '8.11.1'
 }

starters/async-commons-starter/src/main/java/org/reactivecommons/async/starter/config/ReactiveCommonsConfig.java

@@ -1,5 +1,6 @@
 package org.reactivecommons.async.starter.config;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.micrometer.core.instrument.MeterRegistry;
 import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
 import lombok.RequiredArgsConstructor;
@@ -70,6 +71,12 @@ public ObjectMapperSupplier objectMapperSupplier() {
         return new DefaultObjectMapperSupplier();
     }
 
+    @Bean
+    @ConditionalOnMissingBean
+    public ObjectMapper defaultReactiveCommonsObjectMapper(ObjectMapperSupplier supplier) {
+        return supplier.get();
+    }
+
     @Bean
     @ConditionalOnMissingBean(ReactiveReplyRouter.class)
     public ReactiveReplyRouter defaultReactiveReplyRouter() {

starters/async-commons-starter/src/test/java/org/reactivecommons/async/starter/mybroker/MyBrokerProvider.java

@@ -27,7 +27,7 @@ public DomainEventBus getDomainBus() {
     }
 
     @Override
-    public DirectAsyncGateway getDirectAsyncGateway(HandlerResolver resolver) {
+    public DirectAsyncGateway getDirectAsyncGateway() {
         return null;
     }
 

starters/async-kafka-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/KafkaConfigTest.java

@@ -7,6 +7,7 @@
 import org.reactivecommons.async.kafka.converters.json.KafkaJacksonMessageConverter;
 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;
@@ -17,7 +18,9 @@
         RCKafkaConfig.class,
         AsyncKafkaPropsDomain.class,
         KafkaBrokerProviderFactory.class,
-        ReactiveCommonsConfig.class})
+        ReactiveCommonsConfig.class,
+        ReactiveCommonsListenersConfig.class
+})
 class KafkaConfigTest {
     @Autowired
     private KafkaJacksonMessageConverter converter;

starters/async-rabbit-starter/src/test/java/org/reactivecommons/async/starter/impl/rabbit/RabbitMQConfigTest.java

@@ -6,6 +6,7 @@
 import org.reactivecommons.async.rabbit.converters.json.RabbitJacksonMessageConverter;
 import org.reactivecommons.async.starter.config.ConnectionManager;
 import org.reactivecommons.async.starter.config.ReactiveCommonsConfig;
+import org.reactivecommons.async.starter.config.ReactiveCommonsListenersConfig;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 
@@ -15,7 +16,9 @@
         RabbitMQConfig.class,
         AsyncPropsDomain.class,
         RabbitMQBrokerProviderFactory.class,
-        ReactiveCommonsConfig.class})
+        ReactiveCommonsConfig.class,
+        ReactiveCommonsListenersConfig.class
+})
 class RabbitMQConfigTest {
     @Autowired
     private RabbitJacksonMessageConverter converter;