feat: add RabbitPropsCustomizer and KafkaPropsCustomizer for flexible multi-domain configuration (#169)

* feat: enhance AsyncPropsDomain with customizer support and add tests

* feat: add validation for customizer configuration in AsyncKafkaPropsDomain and AsyncPropsDomain

* feat: add RabbitPropsCustomizer and KafkaPropsCustomizer for flexible multi-domain configuration

Author: luisgomez29

async/async-commons/async-commons.gradle

@@ -10,8 +10,8 @@ dependencies {
 
     compileOnly 'io.projectreactor:reactor-core'
     api 'tools.jackson.core:jackson-databind'
-    implementation 'commons-io:commons-io:2.21.0'
-    implementation 'io.cloudevents:cloudevents-core:4.0.1'
+    implementation 'commons-io:commons-io:2.22.0'
+    implementation 'io.cloudevents:cloudevents-core:4.0.2'
 
     testImplementation 'io.projectreactor:reactor-test'
 }

async/async-kafka/async-kafka.gradle

@@ -9,5 +9,5 @@ dependencies {
     api project(':async-commons')
     api project(':cloudevents-json-jackson')
     api 'io.projectreactor.kafka:reactor-kafka:1.3.25'
-    implementation 'io.cloudevents:cloudevents-core:4.0.1'
+    implementation 'io.cloudevents:cloudevents-core:4.0.2'
 }

async/async-rabbit/async-rabbit.gradle

@@ -15,6 +15,6 @@ dependencies {
     api 'com.rabbitmq:amqp-client'
     api 'tools.jackson.core:jackson-databind'
 
-    implementation 'io.cloudevents:cloudevents-core:4.0.1'
+    implementation 'io.cloudevents:cloudevents-core:4.0.2'
     testImplementation 'io.projectreactor:reactor-test'
 }

async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/listeners/GenericMessageListener.java

@@ -9,15 +9,15 @@
 import org.reactivecommons.async.commons.utils.LoggerSubscriber;
 import org.reactivecommons.async.rabbit.InstanceIdentifier;
 import org.reactivecommons.async.rabbit.RabbitMessage;
-import reactor.rabbitmq.AcknowledgableDelivery;
-import reactor.rabbitmq.ConsumeOptions;
 import org.reactivecommons.async.rabbit.communications.ReactiveMessageListener;
 import org.reactivecommons.async.rabbit.communications.TopologyCreator;
-import reactor.rabbitmq.Receiver;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.core.scheduler.Scheduler;
 import reactor.core.scheduler.Schedulers;
+import reactor.rabbitmq.AcknowledgableDelivery;
+import reactor.rabbitmq.ConsumeOptions;
+import reactor.rabbitmq.Receiver;
 import reactor.util.retry.Retry;
 
 import java.time.Duration;
@@ -93,9 +93,18 @@ public void startListener() {
             log.log(Level.INFO, "ATTENTION! Using infinite fast retries as Retry Strategy");
         }
 
-        ConsumeOptions consumeOptions = new ConsumeOptions();
-        consumeOptions.qos(messageListener.prefetchCount());
-        consumeOptions.consumerTag(InstanceIdentifier.getInstanceId(getKind()));
+        ConsumeOptions consumeOptions = new ConsumeOptions()
+                .qos(messageListener.prefetchCount())
+                .consumerTag(InstanceIdentifier.getInstanceId(getKind()))
+                .channelCallback(channel -> channel.addShutdownListener(cause -> {
+                    log.log(Level.WARNING, cause, () -> "Channel shutdown detected in queue " + queueName
+                            + " channel open: " + channel.isOpen() +
+                            " connection open: " + channel.getConnection().isOpen());
+                    if (channel.getConnection().isOpen() && !channel.isOpen()) {
+                        log.warning("Recovering listener for queue: " + queueName);
+                        onTerminate();
+                    }
+                }));
 
         if (createTopology) {
             this.messageFlux = setUpBindings(messageListener.topologyCreator())

async/cloudevents-json-jackson/cloudevents-json-jackson.gradle

@@ -5,6 +5,6 @@ ext {
 
 dependencies {
     api 'tools.jackson.core:jackson-databind'
-    implementation 'io.cloudevents:cloudevents-api:4.0.1'
-    implementation 'io.cloudevents:cloudevents-core:4.0.1'
+    implementation 'io.cloudevents:cloudevents-api:4.0.2'
+    implementation 'io.cloudevents:cloudevents-core:4.0.2'
 }

build.gradle

@@ -12,10 +12,10 @@ buildscript {
 
 plugins {
     id 'jacoco'
-    id 'org.sonarqube' version '7.2.2.6593'
-    id 'org.springframework.boot' version '4.0.4' apply false
+    id 'org.sonarqube' version '7.3.0.8198'
+    id 'org.springframework.boot' version '4.0.6' apply false
     id 'io.github.gradle-nexus.publish-plugin' version '2.0.0'
-    id 'co.com.bancolombia.cleanArchitecture' version '4.3.0'
+    id 'co.com.bancolombia.cleanArchitecture' version '4.4.1'
 }
 
 repositories {