[ https://issues.apache.org/jira/browse/CAMEL-12324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16389191#comment-16389191 ]
Claus Ibsen commented on CAMEL-12324: ------------------------------------- I have improved the docs to explain about this https://github.com/apache/camel/blob/master/components/camel-rabbitmq/src/main/docs/rabbitmq-component.adoc#routing-between-exchanges > Issue:Camel rabbitmq publishes message to consumer exchange instead of > publisher exchange > ----------------------------------------------------------------------------------------- > > Key: CAMEL-12324 > URL: https://issues.apache.org/jira/browse/CAMEL-12324 > Project: Camel > Issue Type: Bug > Components: camel-rabbitmq > Affects Versions: 2.20.0, 2.20.1, 2.20.2 > Reporter: zoheb > Priority: Major > Attachments: camel-rmq-test.zip > > > Hello Team, > I am facing issue when i tried to use camel rabbitmq components for version > 2.20.x. > The issue is happening when i have camel context containing route that > consumes from rabbitmq queue and publishes to rabbitmq exchange .What happens > is camel rabbitmq is publishing to consumer exchange instead of given > producer exchange and in this way it goes in infinite cycle. Here is sample > route for reference which can easily reproduce the issue. > > <beans xmlns="http://www.springframework.org/schema/beans" > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" > xmlns:context="http://www.springframework.org/schema/context" > xmlns:camel="http://camel.apache.org/schema/spring" > xsi:schemaLocation=" > http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans.xsd > http://www.springframework.org/schema/context > http://www.springframework.org/schema/context/spring-context.xsd > http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd"> > > > <camel:camelContext id="rmqtest"> > > > > <camel:route id="java"> > > <camel:from > uri="rabbitmq://localhost:8311/test_exchange_in?username=admin&password=admin&vhost=/&queue=test_queue_in&automaticRecoveryEnabled=true&concurrentConsumers=2&durable=false&arg.queue.x-message-ttl=5000&networkRecoveryInterval=10000" > /> > <camel:log message="incoming message ${body}. Modifying message body." > loggingLevel="INFO"/> > <camel:setBody> <camel:simple trim="false">Message modified.</camel:simple> > </camel:setBody> > <camel:to > uri="rabbitmq://localhost:8311/test_exchange_out?username=admin&password=admin&vhost=/&skipQueueDeclare=true&exchangeType=headers&automaticRecoveryEnabled=true&autoDelete=false&networkRecoveryInterval=10000" > /> > <camel:log message="publish done" loggingLevel="INFO"/> > </camel:route> > > > </camel:camelContext> > > </beans> > > > > > I have also attached sample project to reproduce the issue. > Request you to please look into the issue and let us know the solution or fix > if any. > Thanks & regards, > Zoheb > -- This message was sent by Atlassian JIRA (v7.6.3#76005)