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

["zoheb (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/CAMEL-12324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16388886#comment-16388886 ] 

zoheb edited comment on CAMEL-12324 at 3/7/18 4:06 AM:
-------------------------------------------------------

Hi Andrea,

 

I think this is a bug in camel 2.20.x rabbitmq component I tried many things but it didn't worked. 

Request team to please look into this as it is a major blocker in case camel context contains route that consume from rabbitmq and publishes to rabbitmq.


was (Author: zohebp):
Hi Andrea,

 

I think this is a bug in camel 2.20.x rabbitmq component I tried many things but it didn't worked. 

Request team to please look into this as it is a major blocker in case camel context contains route that consumer from rabbitmq and publishes to rabbitmq.

> 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&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)