Merge branch 'master' into feature/fix-bugs

Author: lugomez29

CHANGELOG.md

@@ -1,5 +1,21 @@
 # Changelog
 
+## [v5.6.2](https://github.com/reactive-commons/reactive-commons-java/tree/v5.6.2) (2025-09-10)
+
+[Full Changelog](https://github.com/reactive-commons/reactive-commons-java/compare/v5.6.2-beta.1...v5.6.2)
+
+**Merged pull requests:**
+
+- fix\(queueType\): Leave by default the queueType defined in virtualhost at server level [\#150](https://github.com/reactive-commons/reactive-commons-java/pull/150) ([juancgalvis](https://github.com/juancgalvis))
+
+## [v5.6.2-beta.1](https://github.com/reactive-commons/reactive-commons-java/tree/v5.6.2-beta.1) (2025-09-08)
+
+[Full Changelog](https://github.com/reactive-commons/reactive-commons-java/compare/v5.6.1...v5.6.2-beta.1)
+
+**Closed issues:**
+
+- Add support for quorum queues in RabbitMQ connections [\#148](https://github.com/reactive-commons/reactive-commons-java/issues/148)
+
 ## [v5.6.1](https://github.com/reactive-commons/reactive-commons-java/tree/v5.6.1) (2025-09-03)
 
 [Full Changelog](https://github.com/reactive-commons/reactive-commons-java/compare/v5.6.0...v5.6.1)

async/async-rabbit/src/main/java/org/reactivecommons/async/rabbit/communications/TopologyCreator.java

@@ -24,7 +24,7 @@ public class TopologyCreator {
 
     public TopologyCreator(Sender sender, String queueType) {
         this.sender = sender;
-        this.queueType = queueType != null ? queueType : "classic";
+        this.queueType = queueType;
     }
 
     public Mono<AMQP.Exchange.DeclareOk> declare(ExchangeSpecification exchange) {
@@ -90,14 +90,17 @@ public Mono<AMQP.Queue.DeclareOk> declareQueue(String name, Optional<Integer> ma
 
     protected QueueSpecification fillQueueType(QueueSpecification specification) {
         String resolvedQueueType = this.queueType;
-        if (specification.isAutoDelete() || specification.isExclusive()) {
+        if ("quorum".equals(resolvedQueueType)
+                && (specification.isAutoDelete() || specification.isExclusive())) {
             resolvedQueueType = "classic";
         }
         Map<String, Object> args = specification.getArguments();
         if (args == null) {
             args = new HashMap<>();
         }
-        args.put("x-queue-type", resolvedQueueType);
+        if (resolvedQueueType != null) {
+            args.put("x-queue-type", resolvedQueueType);
+        }
         specification.arguments(args);
         return specification;
     }

docs/docs/reactive-commons/9-configuration-properties.md

@@ -31,7 +31,7 @@ app:
       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
       brokerType: "rabbitmq" # please don't change this value
-      queueType: classic # you can change the queue type to 'quorum' if your RabbitMQ cluster supports it
+      queueType: null # you can set to 'classic' or to 'quorum' if your RabbitMQ cluster supports it, by default it will take the virtual host default queue type
       flux:
         maxConcurrency: 250 # max concurrency of listener flow
       domain:

gradle.properties

@@ -1,3 +1,3 @@
-version=5.6.1
+version=5.6.2
 toPublish=domain-events-api,async-commons-api,async-commons,shared-starter,async-rabbit,async-commons-rabbit-standalone,async-commons-rabbit-starter,async-kafka,async-kafka-starter,async-commons-starter
 onlyUpdater=true

starters/async-rabbit-starter/src/main/java/org/reactivecommons/async/rabbit/config/props/AsyncProps.java

@@ -83,6 +83,6 @@ public Boolean getListenReplies() {
     private String brokerType = "rabbitmq";
 
     @Builder.Default
-    private String queueType = "classic"; // or "quorum"
+    private String queueType = null; // "classic" or "quorum"
 
 }