Return-Path: 
 <users-return-19960-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 EE4373730
	for <apmail-camel-users-archive@www.apache.org>;
 Wed,  4 May 2011 11:12:52 +0000 (UTC)
Received: (qmail 97556 invoked by uid 500); 4 May 2011 11:12:52 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 97531 invoked by uid 500); 4 May 2011 11:12:52 -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 97523 invoked by uid 99); 4 May 2011 11:12:52 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 04 May 2011 11:12:52 +0000
X-ASF-Spam-Status: No, hits=-0.7 required=5.0
	tests=FREEMAIL_FROM,RCVD_IN_DNSWL_LOW,RFC_ABUSE_POST,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.212.177 as permitted sender)
Received: from [209.85.212.177] (HELO mail-px0-f177.google.com)
 (209.85.212.177)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 04 May 2011 11:12:48 +0000
Received: by pxi10 with SMTP id 10so628064pxi.22
        for <users@camel.apache.org>; Wed, 04 May 2011 04:12:28 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=gamma;
        h=domainkey-signature:mime-version:in-reply-to:references:from:date
         :message-id:subject:to:content-type:content-transfer-encoding;
        bh=t1k7DE1AlBi0cBPyVTrQ/SAX5m0bvxutChgGeVa24oo=;
        b=Q/0ZTIgsjnwq6b0f+EW5RWpPHFls6uCsCFlT3oSEWdE3hMgoF/NoQrCnBNMNXYgW+M
         XWrJjXIWrs5qydJewu94vuTlpWzwS66u43b9IrUTj1c8iw6YWmjWLuNr8T0fUVw3fF0Z
         0NcprxQlab8R/gQ/B2y9Ft8tz920uHoG3C8cA=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=b9gw5/Wuk0J2FylMW86eKwVWkMCKuufeJvFWVUJColWCEyHx+ksR/uBd+HKxHJMQmX
         nB6a/YT8J0Uybt3/6qDWzCmP9fT7XURm32z9KHTa+UFk/TOjJvw+OObLbeiBwAbQjm0P
         /FJFnb7ysrn85pIM5bboe65+aEbhfs1ru471U=
Received: by 10.68.47.198 with SMTP id f6mr1389194pbn.511.1304507548068; Wed,
 04 May 2011 04:12:28 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.68.57.1 with HTTP; Wed, 4 May 2011 04:12:08 -0700 (PDT)
In-Reply-To: <BANLkTimvoqKKaxmeDwd-NDxZr2fqBScyJQ@mail.gmail.com>
References: <BANLkTimvoqKKaxmeDwd-NDxZr2fqBScyJQ@mail.gmail.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Wed, 4 May 2011 13:12:08 +0200
Message-ID: <BANLkTimTiW1hpTNRSYRo6gy7kFt18Ze=gA@mail.gmail.com>
Subject: Re: Another problem?
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-2022-JP
Content-Transfer-Encoding: 7bit

Hi

Its a bit hard to follow your question?

Concurrency all starts with consumers. So if you have a single thread
that sends a message to "direct:casemx" then there is only a single
thread processing in that given route.

You can use a JDK thread pool executor to send concurrent messages to
the "direct:casemx" endpoint and have concurrent threads process
messages in that route.



On Wed, May 4, 2011 at 1:02 PM, Muhammad Ichsan <ichsan@gmail.com> wrote:
> Dear All
>
> I found another problem in Camel. Given context file (the java bean
> code is self-explainable):
>
> <route>
>                        <from uri="direct:casemx" />
>
>                        <setExchangePattern pattern="InOut" />
>                        <to uri="activemq:preparation" />
>
>                        <to uri="bean:mocky?method=delay2000" />
>
>                        <to uri="mock:result" />
>                </route>
>
>                <route>
>                        <from uri="activemq:preparation" />
>                        <to uri="bean:mocky?method=delay1000" />
>                        <to uri="log:ho" />
>                </route>
>
>
> With activemq concurrency 10. If I send 8 message at once into
> direct:casemx, delay1000 method will be called concurrently. But...
> delay2000 is not!!! Do I miss something here? Or this is just another
> bug???
>
> --
> ~The best men are men who benefit to others
> http://michsan.web.id　一緒に勉強しましょう！
>
> Yang berkualitas memang beda rasanya!
> http://rizqi-cookies.com
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
CamelOne 2011: http://fusesource.com/camelone2011/
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/