Return-Path: 
 <users-return-40353-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
X-Original-To: apmail-camel-users-archive@www.apache.org
Delivered-To: apmail-camel-users-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 8CB4A10D7D
	for <apmail-camel-users-archive@www.apache.org>;
 Thu, 20 Jun 2013 10:53:16 +0000 (UTC)
Received: (qmail 85931 invoked by uid 500); 20 Jun 2013 10:53:15 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 85890 invoked by uid 500); 20 Jun 2013 10:53:14 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Received: (qmail 85881 invoked by uid 99); 20 Jun 2013 10:53:13 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Jun 2013 10:53:13 +0000
X-ASF-Spam-Status: No, hits=0.6 required=5.0
	tests=RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.223.178 as permitted sender)
Received: from [209.85.223.178] (HELO mail-ie0-f178.google.com)
 (209.85.223.178)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Jun 2013 10:53:09 +0000
Received: by mail-ie0-f178.google.com with SMTP id u16so16434365iet.9
        for <users@camel.apache.org>; Thu, 20 Jun 2013 03:52:49 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=20120113;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type;
        bh=GyoOI4vBFvWjW+5RW7ebC7UDInedTaieP15rC5rHOIM=;
        b=GNh+oxbT0ZuWZouunitslQFLm7WGZ3uRQ4nQi5x6PATZrz9ou4AtZte5Dp8zgzD7ri
         FKcc2HqQYK2zXlWXHelvH/HLKLpcUPSPu3QwZsI2yJGpNEEsYlBTkC2cKGQeYR8a2qMa
         nqnUrjohobsFMVj7kzYVVf7++n/uzpRN16/dqZMTMS12kVYPKTS3OzFvxhND5hksfFFd
         i7VsmvJUKiiiq6VAOTfdBk3WEyJ1cYtRsScdF5VkGcVfUd2oU2tvaYtFfLlVlRBoxenn
         Lpq/+duu1bvi+HyGT9lEKU6xDwMgiK2P/YGMkt+GVAbtpxBE1iaz4rjLPCsGPJCwwgb3
         QFqw==
X-Received: by 10.50.132.98 with SMTP id ot2mr12380622igb.38.1371725568960;
 Thu, 20 Jun 2013 03:52:48 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.64.86.233 with HTTP; Thu, 20 Jun 2013 03:52:28 -0700 (PDT)
In-Reply-To: <1371723982736-5734427.post@n5.nabble.com>
References: <1371723982736-5734427.post@n5.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Thu, 20 Jun 2013 12:52:28 +0200
Message-ID: 
 <CAGB5yN=XG781U1_F1mbvU92vi-7+Dic0YfVxP=znV3Ng+u=x+w@mail.gmail.com>
Subject: Re: Content based routing with InOut pattern and exclusive reply
 queue
To: "users@camel.apache.org" <users@camel.apache.org>
Content-Type: text/plain; charset=ISO-8859-1
X-Virus-Checked: Checked by ClamAV on apache.org

Hi

The reply queue is NOT exclusive. You use it 2 times for route1 and
route2 in the content based router.


On Thu, Jun 20, 2013 at 12:26 PM, Tomas Potocky <tomas.potocky@hp.com> wrote:
> Hi folks,
> I've found some strange behaviour using content based routing in camel. Can
> someone tell me what's wrong with following setup and why I get
> PersistentQueueReplyManager:86 - Reply received for unknown correlationID
> for route2 when using Exclusive queue for replies? If I use temporary queues
> for replies everything works.
>
>     <bean id="amq"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
>         <property name="brokerURL"
> value="vm://deBroker?marshal=false&amp;broker.persistent=false" />
>     </bean>
>     <camelContext id="camelContext"
> xmlns="http://camel.apache.org/schema/spring">
>         <route id="main">
>             <from uri="direct:start" />
>             <choice>
>                 <when>
>                     <simple>${property.route} == 'route1'</simple>
>                     <to
> uri="amq:queue:route1?replyTo=route_reply&amp;replyToType=Exclusive"
> pattern="InOut" />
>                 </when>
>                 <when>
>                     <simple>${property.route} == 'route2'</simple>
>                     <to
> uri="amq:queue:route2?replyTo=route_reply&amp;replyToType=Exclusive"
> pattern="InOut" />
>                 </when>
>             </choice>
>             <to uri="mock:result" />
>         </route>
>
>         <route id="route1">
>             <from uri="amq:queue:route1" />
>             <log message="received ${body}" />
>             <to uri="mock:result1" />
>         </route>
>         <route id="route2">
>             <from uri="amq:queue:route2" />
>             <log message="received ${body}" />
>             <to uri="mock:result2" />
>         </route>
>     </camelContext>
>
> I'm producing following to start endpoint:
>         producer.sendBodyAndProperty("route1 body", "route", "route1");
>         producer.sendBodyAndProperty("route2 body", "route", "route2");
>
> Thanks
>
>
>
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Content-based-routing-with-InOut-pattern-and-exclusive-reply-queue-tp5734427.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-----------------
www.camelone.org: The open source integration conference.

Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen