Return-Path: 
 <users-return-31776-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 D5DB5D0E4
	for <apmail-camel-users-archive@www.apache.org>;
 Fri, 17 Aug 2012 03:52:28 +0000 (UTC)
Received: (qmail 10136 invoked by uid 500); 17 Aug 2012 03:52:27 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 10009 invoked by uid 500); 17 Aug 2012 03:52:22 -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 9971 invoked by uid 99); 17 Aug 2012 03:52:21 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Aug 2012 03:52:21 +0000
X-ASF-Spam-Status: No, hits=2.0 required=5.0
	tests=SPF_NEUTRAL,URI_HEX
X-Spam-Check-By: apache.org
Received-SPF: neutral (nike.apache.org: 216.139.236.26 is neither permitted
 nor denied by domain of javakurious@gmail.com)
Received: from [216.139.236.26] (HELO sam.nabble.com) (216.139.236.26)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Aug 2012 03:52:15 +0000
Received: from [192.168.236.26] (helo=sam.nabble.com)
	by sam.nabble.com with esmtp (Exim 4.72)
	(envelope-from <javakurious@gmail.com>)
	id 1T2DbG-0001WS-9V
	for users@camel.apache.org; Thu, 16 Aug 2012 20:51:54 -0700
Date: Thu, 16 Aug 2012 20:51:54 -0700 (PDT)
From: javakurious <javakurious@gmail.com>
To: users@camel.apache.org
Message-ID: <1345175514286-5717567.post@n5.nabble.com>
Subject: aggregator aggregation completion
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

I am looking for some tips to correctly use Aggregator component. 

The scenario is that I am getting a request in xml format, and I process
that request and get a response in XML format as well. But the request and
response are two completely different format. My goal is to create a new XML
document that combines the original request and the corresponding response,
set it as a body of the Aggregated Exchange and send the exchange to a bean
to write to database.

         <route id= "processing">
            <from uri="direct:orderRequestQueue"/>            
            <wireTap uri="seda:auditRequestQueue"/> 
            <process ref="requestProcessor"/> 
            <wireTap uri="seda:auditRequestQueue"/>     
         </route>  
 
        <route id="auditing">
            <from uri="seda:auditRequestQueue"/>            
            <aggregate strategyRef="combineXSLTAggregateStrategy"
completionSize="2">
                <correlationExpression>                    
                    <simple>header.breadcrumbId</simple>
                </correlationExpression>                
                <bean ref="db-processor" method="writeToDatabase"/>
            </aggregate>
        </route>

Above, I am trying to send the request and the response to
'seda:auditRequestQueue'. The strategy ref is supposed to run a
transformation to create a new xml document. I am using header.breadcrumbId
as the correlation expression. I have set the completionSize to '2', so once
both request and response is set to auditRequestQueue, the strategyRef is
going to be executed. 

But, for some reason the strategyRef is never executed, the route keeps
waiting for 2 related messages to arrive. 

What am I doing wrong ??? How can I debug it ?

Thanks for any help !



--
View this message in context: http://camel.465427.n5.nabble.com/aggregator-aggregation-completion-tp5717567.html
Sent from the Camel - Users mailing list archive at Nabble.com.