[CAMEL-9561] RabbitMQ InOut Producer generates operation not permitted on the default exchange when using dynamic exchange

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Information Provided
• Affects Version/s: 2.16.2
• Fix Version/s: Future
• Component/s: camel-rabbitmq
• Estimated Complexity: Advanced
• Assignee: Unassigned
• Reporter: Arnaud CHOTARD
• Created: 02/Feb/16 15:29
• Updated: 02/Sep/22 09:15
• Resolved: 02/Sep/22 09:15

Description

The use case uses a RabbitMQ InOut Producer with a dynamic RabbitMQ exchange name header :

from("direct:route")
   .setHeader(RabbitMQConstants.EXCHANGE_NAME, constant("exchange"))
   .inOut("rabbitmq:///?connectionFactory=...")

The exchange name is only set on header, not in RabbitMQ endpoint URI.

This generates a RabbitMQ Exception :

com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=403, reply-text=ACCESS_REFUSED - operation not permitted on the default exchange, class-id=50, method-id=20)

The problem is located when doing queueBinding on reply to queue in org.apache.camel.component.rabbitmq.reply.TemporaryQueueReplyManager

protected Connection createListenerContainer() throws Exception

channel.queueBind(getReplyTo(), endpoint.getExchangeName(), getReplyTo());

The header exchange name should be used instead of the endpoint exchange name.