Skip to content
This repository was archived by the owner on Sep 26, 2025. It is now read-only.

Commit ebd0163

Browse files
committed
Use spec arguments for non-durable, AD, exclusive queue declaration
References #44
1 parent a9fa405 commit ebd0163

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/reactor/rabbitmq/Sender.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ public Mono<AMQP.Queue.DeclareOk> declareQueue(QueueSpecification specification,
238238
.durable(false)
239239
.exclusive(true)
240240
.autoDelete(true)
241-
.arguments(null)
241+
.arguments(specification.getArguments())
242242
.build();
243243
} else {
244244
declare = new AMQImpl.Queue.Declare.Builder()

0 commit comments

Comments
 (0)