Skip to content

Commit 1d4f956

Browse files
committed
fix(queueType): Leave by default the queueType defined in virtualhost at server level
1 parent 2cdc978 commit 1d4f956

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,8 @@ public Mono<AMQP.Queue.DeclareOk> declareQueue(String name, Optional<Integer> ma
9090

9191
protected QueueSpecification fillQueueType(QueueSpecification specification) {
9292
String resolvedQueueType = this.queueType;
93-
if (specification.isAutoDelete() || specification.isExclusive()) {
93+
if ("quorum".equals(resolvedQueueType)
94+
&& (specification.isAutoDelete() || specification.isExclusive())) {
9495
resolvedQueueType = "classic";
9596
}
9697
Map<String, Object> args = specification.getArguments();

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
1-
version=5.6.1
1+
version=5.6.3
22
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
33
onlyUpdater=true

0 commit comments

Comments
 (0)