[jira] [Created] (CAMEL-12324) Issue:Camel rabbitmq publishes message to consumer exchange instead of publisher exchange

[zoheb (JIRA)]

zoheb created CAMEL-12324:
-----------------------------

             Summary: 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.2, 2.20.1, 2.20.0
            Reporter: zoheb
         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&amp;password=admin&amp;vhost=/&amp;queue=test_queue_in&amp;automaticRecoveryEnabled=true&amp;concurrentConsumers=2&amp;durable=false&amp;arg.queue.x-message-ttl=5000&amp;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&amp;password=admin&amp;vhost=/&amp;skipQueueDeclare=true&amp;exchangeType=headers&amp;automaticRecoveryEnabled=true&amp;autoDelete=false&amp;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)