camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From souciance <souciance.eqdam.ras...@gmail.com>
Subject Example for Camel-7860
Date Wed, 14 Oct 2015 19:50:31 GMT
Hello,

I am trying to get the request/reply RabbitMQ to work as stated in :
https://issues.apache.org/jira/browse/CAMEL-7860

This is the code I have written:

from("direct:monkey").setExchangePattern(ExchangePattern.InOut)
    	.setBody(constant(monkey))
        .setHeader("rabbitmq.EXCHANGE_NAME", constant("marc"))
        .setHeader("rabbitmq.ROUTING_KEY", constant("test"))
        .setHeader("rabbitmq.REPLY_TO", constant("MARCMESSAGE.REPLY"))
        .setHeader("rabbitmq.CORRELATIONID", constant(correlationid))
       
.to("rabbitmq://localhost:5672/marc?routingKey=test&username=souciance&password=souciance&exchangeType=topic&autoDelete=false&declare=false")
    	.log("${body}");

What I don't understand is, will Camel pick up message sent by the backend
to the queue MARCMESSAGE.REPLY and match against the correlation_id? I have
tried to do that manually but nothing is picked up by Camel. I am a bit
confused on how the actual scenario is similar to the RPC as stated in jira
since in the RPC model you combine request/reply with correlationids. Is
that also what happens here?

Thanks for any hints.
Souciance



--
View this message in context: http://camel.465427.n5.nabble.com/Example-for-Camel-7860-tp5772659.html
Sent from the Camel Development mailing list archive at Nabble.com.

Mime
View raw message