feat: customize the RabbitMQ connection

Author: lugomez29

async/async-commons/src/main/java/org/reactivecommons/async/commons/DiscardNotifier.java

@@ -3,6 +3,7 @@
 import org.reactivecommons.async.commons.communications.Message;
 import reactor.core.publisher.Mono;
 
+@FunctionalInterface
 public interface DiscardNotifier {
     Mono<Void> notifyDiscard(Message message);
 }

async/async-commons/src/main/java/org/reactivecommons/async/commons/utils/matcher/Matcher.java

@@ -2,6 +2,7 @@
 
 import java.util.Set;
 
+@FunctionalInterface
 public interface Matcher {
     String match(Set<String> sources, String target);
 }

docs/docs/migration-guides.md

@@ -6,6 +6,24 @@ sidebar_position: 4
 
 ## From 5.x.x to 6.x.x
 
+### New Features
+
+- **Connection customization:** You can now customize the RabbitMQ connection by defining a
+  `ConnectionFactoryCustomizer` bean. For more details,
+  see [Customizing the connection](/reactive-commons-java/docs/reactive-commons/configuration_properties/rabbitmq#customizing-the-connection).
+
+```java title="Programmatic configuration"
+
+@Bean
+public ConnectionFactoryCustomizer connectionFactoryCustomizer() {
+    return (ConnectionFactoryCustomizer) (asyncProps, connectionFactory) -> {
+        connectionFactory.setExceptionHandler(new MyCustomExceptionHandler()); // Optional custom exception handler
+        connectionFactory.setCredentialsProvider(new MyCustomCredentialsProvider()); // Optional custom credentials provider
+        return connectionFactory;
+    };
+}
+```
+
 ### Change notes
 
 - The configuration property `listenReplies` for RabbitMQ now defaults to `null`. Previously, it was `true`, causing all
@@ -25,7 +43,6 @@ app:
 ```
 
 ```java title="Programmatic configuration"
-
 @Configuration
 public class MyDomainConfig {
 
@@ -56,7 +73,6 @@ app:
 ```
 
 ```java title="Programmatic configuration"
-
 @Configuration
 public class MyDomainConfig {
 
@@ -78,7 +94,8 @@ public class MyDomainConfig {
 
 ### New Features
 
-- Support for multiple brokers: It is now possible to configure and connect to up to two brokers simultaneously, using
+- **Support for multiple brokers:** It is now possible to configure and connect to up to two brokers simultaneously,
+  using
   independent domains in the configuration.
 
 ### Change notes
@@ -118,7 +135,6 @@ app:
 Before: the connection was defined manually in a Java class, as shown below:
 
 ```java
-
 @Log4j2
 @Configuration
 @RequiredArgsConstructor
@@ -180,7 +196,6 @@ app:
 Domains can also be configured programmatically:
 
 ```java title="Programmatic configuration"
-
 @Configuration
 public class MyDomainConfig {
 

docs/docs/reactive-commons/configuration_properties/1-rabbitmq.md

@@ -20,7 +20,7 @@ app:
       listenReplies: null # Allows true or false values. If you're using the ReqReply pattern, set it to true. If you don't, set it to false.
       createTopology: true # if your organization have restrictions with automatic topology creation you can set it to false and create it manually or by your organization process.
       delayedCommands: false # Enable to send a delayed command to an external target
-      prefetchCount: 250 # is the maximum number of in flight messages you can reduce it to process less concurrent messages, this settings acts per instance of your service
+      prefetchCount: 250 # is the maximum number of in flight messages you can reduce it to process less concurrent messages, this setting acts per instance of your service
       useDiscardNotifierPerDomain: false # if true it uses a discard notifier for each domain,when false it uses a single discard notifier for all domains with default 'app' domain
       enabled: true # if you want to disable this domain you can set it to false
       mandatory: false # if you want to enable mandatory messages, you can set it to true, this will throw an exception if the message cannot be routed to any queue
@@ -168,7 +168,7 @@ import java.lang.reflect.GenericArrayType;
 
 @Log4j2
 @Configuration
-public class AsyncEventBusConfig {
+public class RabbitMQConfig {
 
     // TODO: You should create the GenericManager bean as indicated in Secrets Manager library
     @Bean
@@ -188,10 +188,27 @@ public class AsyncEventBusConfig {
         return genericManager.getSecret(secretName, RabbitConnectionProperties.class).toRabbitProperties();
     }
 }
+```
+
+## Customizing the connection
 
+For advanced control over the RabbitMQ connection, you can define a `ConnectionFactoryCustomizer` bean. This allows you
+to configure options that are not exposed through standard properties, such as custom timeouts, SSL/TLS settings,
+or automatic recovery strategies:
+
+```java
+
+@Bean
+public ConnectionFactoryCustomizer connectionFactoryCustomizer() {
+    return (ConnectionFactoryCustomizer) (asyncProps, connectionFactory) -> {
+        connectionFactory.setExceptionHandler(new MyCustomExceptionHandler()); // Optional custom exception handler
+        connectionFactory.setCredentialsProvider(new MyCustomCredentialsProvider()); // Optional custom credentials provider
+        return connectionFactory;
+    };
+}
 ```
 
-## Connections and Channels
+## Connections and channels
 
 Reactive Commons establishes **a single connection to the RabbitMQ broker**, which is reused for all messaging
 operations, both sending and listening. However, the number of open **channels** within that connection varies depending
@@ -201,7 +218,7 @@ shows how the number of channels changes according to the applied configuration.
 In the context of this documentation, a domain refers to a connection with a broker. The configuration supports up to
 two brokers, which means the described scenarios are limited to a maximum of two domains.
 
-### Annotations Used in the Tables
+### Annotations used in the tables
 
 **[1] Annotations for sending messages:**
 

gradle/wrapper/gradle-wrapper.jar

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

gradle/wrapper/gradle-wrapper.properties

@@ -1,7 +1,7 @@
 #!/bin/sh
 
 #
-# Copyright © 2015-2021 the original authors.
+# Copyright © 2015 the original authors.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -114,7 +114,6 @@ case "$( uname )" in                #(
   NONSTOP* )        nonstop=true ;;
 esac
 
-CLASSPATH="\\\"\\\""
 
 
 # Determine the Java command to use to start the JVM.
@@ -172,7 +171,6 @@ fi
 # For Cygwin or MSYS, switch paths to Windows format before running java
 if "$cygwin" || "$msys" ; then
     APP_HOME=$( cygpath --path --mixed "$APP_HOME" )
-    CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" )
 
     JAVACMD=$( cygpath --unix "$JAVACMD" )
 
@@ -212,7 +210,6 @@ DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
 
 set -- \
         "-Dorg.gradle.appname=$APP_BASE_NAME" \
-        -classpath "$CLASSPATH" \
         -jar "$APP_HOME/gradle/wrapper/gradle-wrapper.jar" \
         "$@"
 

gradlew

@@ -70,11 +70,10 @@ goto fail
 :execute
 @rem Setup the command line
 
-set CLASSPATH=
 
 
 @rem Execute Gradle
-"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" -jar "%APP_HOME%\gradle\wrapper\gradle-wrapper.jar" %*
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -jar "%APP_HOME%\gradle\wrapper\gradle-wrapper.jar" %*
 
 :end
 @rem End local scope for the variables with windows NT shell

gradlew.bat

@@ -3,8 +3,9 @@ allprojects {
     apply plugin: 'jacoco'
 
     java {
-        sourceCompatibility = JavaVersion.VERSION_17
-        targetCompatibility = JavaVersion.VERSION_17
+        toolchain {
+            languageVersion = JavaLanguageVersion.of(17)
+        }
     }
 
     repositories {
@@ -182,5 +183,7 @@ tasks.register('generateMergedReport', JacocoReport) {
 }
 
 tasks.named('wrapper') {
-    gradleVersion = '8.14.3'
+    gradleVersion = '9.1.0'
+    validateDistributionUrl = true
+    distributionSha256Sum = "a17ddd85a26b6a7f5ddb71ff8b05fc5104c0202c6e64782429790c933686c806"
 }

main.gradle

@@ -1,3 +1,8 @@
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter'
+}
+
+test {
+    // Disable error when no tests are found (for example modules)
+    failOnNoDiscoveredTests = false
 }