Can't listen to a quorum queue using a JMS consumer

[tangi11]

Hello,
I'm trying to implement a JMS consumer for a quorum queue, using rabbitmq-jms 2.5.0, and it seems the destination "queueDeclareArguments" are not sent to RabbitMQ at the connection time. I've read the documentation and I can't figure out what's happening, maybe I'm doing something wrong, and I'd really appreciate someone's help :-)
Oh, and... I'm a newbie with RabbitMQ.

1. A quorum queue named "metricsDestination" is created using the RabbitMQ management console
2. Definition of the Destination bean:

    @Bean
    public Destination metricsDestination() {
        RMQDestination jmsDestination = new RMQDestination("metricsDestination", true, false, Map.of("x-queue-type", "quorum"));
        jmsDestination.setDeclared(true);
        return jmsDestination;
    }

3. Definition of the JMS consumer:

    @JmsListener(destination = "metricsDestination", containerFactory = "metricsContainerFactory")
    public void receiveMetricsMessage(String metricsMessageString) {
        log.info("received message='{}'", metricsMessageString);
        ...

Now, the error message received at startup, notably "RabbitMQ exception on queue declare name(metricsDestination), durable(true), exclusive(false), auto-delete(false), arguments(null + null)":

2022-07-19 13:23:06.683  INFO [sw-metrics-ws,,] 22832 --- [           main] c.t.l.metricsws.MetricsWsApplication     : Started MetricsWsApplication in 15.283 seconds (JVM running for 16.702)
2022-07-19 13:23:06.685 ERROR [sw-metrics-ws,,] 22832 --- [ntContainer#0-1] com.rabbitmq.jms.client.RMQSession       : RabbitMQ exception on queue declare name(metricsDestination), durable(true), exclusive(false), auto-delete(false), arguments(null + null)

java.io.IOException: null
	at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:147) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:968) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDeclare(AutorecoveringChannel.java:343) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.jms.client.RMQSession.declareRMQQueue(RMQSession.java:934) ~[rabbitmq-jms-2.5.0.jar:2.5.0]
	at com.rabbitmq.jms.client.RMQSession.createQueue(RMQSession.java:872) ~[rabbitmq-jms-2.5.0.jar:2.5.0]
	at brave.jms.TracingSession.createQueue(TracingSession.java:178) ~[brave-instrumentation-jms-5.13.9.jar:na]
	at org.springframework.jms.support.destination.DynamicDestinationResolver.resolveQueue(DynamicDestinationResolver.java:85) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.support.destination.DynamicDestinationResolver.resolveDestinationName(DynamicDestinationResolver.java:59) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.support.destination.JmsDestinationAccessor.resolveDestinationName(JmsDestinationAccessor.java:115) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.createListenerConsumer(AbstractPollingMessageListenerContainer.java:223) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1264) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1236) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1227) ~[spring-jms-5.3.20.jar:5.3.20]
	at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1120) ~[spring-jms-5.3.20.jar:5.3.20]
	at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-type' for queue 'metricsDestination' in vhost '/': received none but current is the value 'quorum' of type 'longstr', class-id=50, method-id=10)
	at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:502) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:293) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:141) ~[amqp-client-5.14.2.jar:5.14.2]
	... 14 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - inequivalent arg 'x-queue-type' for queue 'metricsDestination' in vhost '/': received none but current is the value 'quorum' of type 'longstr', class-id=50, method-id=10)
	at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:517) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:341) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:182) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:114) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:739) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQConnection.access$300(AMQConnection.java:47) ~[amqp-client-5.14.2.jar:5.14.2]
	at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:666) ~[amqp-client-5.14.2.jar:5.14.2]
	... 1 common frames omitted

I thank you for any help you could provide.
Best regards,
Tangi

[acogoluegnes]

You should try the BeanFactoryDestinationResolver class in your metricsContainerFactory bean and make sure the name of the destination matches the name of the bean name (this is the case currently).

And remove the jmsDestination.setDeclared(true); line.

[tangi11]

It works wonderfully, thanks Arnaud !
For anyone interested, I've just added:

    @Autowired
    private ApplicationContext context;
    ...
    factory.setDestinationResolver(new BeanFactoryDestinationResolver(context));