Mailing-List: contact dev-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@camel.apache.org
Date: Wed, 6 Jan 2016 07:50:58 -0700 (MST)
From: "web_nabble@sunilsamuel.com" <web_nabble@sunilsamuel.com>
To: dev@camel.apache.org
Message-ID: <1452091858463-5775895.post@n5.nabble.com>
Subject: PollEnrich + JPA + setCompletionFromBatchConsumer + aggregator
MIME-Version: 1.0
Content-Type: multipart/alternative;
	boundary="----=_Part_198622_378598793.1452091858464"

------=_Part_198622_378598793.1452091858464
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hello,
I am using Apache Camel 2.12 (Fuse 6.1).  I am trying to use the JPA
consumer to consume from a database at every given interval using a timer. 
I like to consume all of the records that match the search criteria using
the aggregator.  If the JPA consumer is a standalone route, I can use the
aggregate EIP as follows:

from ("jpa://com.cigna.upp.model.CustomerAccount?consumer.nativeQuery=" +	
"SELECT A, B, C, FROM MYTABLE WHERE CLNT_ACCT_NUM='5'" +	
"&consumeDelete=false" +		"&consumer.delay=6000" +	
"&consumer.resultClass=com.myapp.model.CustomerAccount")
.aggregate(constant(true), new GroupedExchangeAggregationStrategy())
.beanRef("jpaRouterHelper","processGroupedExchanges")
.setCompletionFromBatchConsumer(true)
Given the above route, I will get all records that match the search criteria
using the GroupedExchangeAggregationStrategy().  That is, by the time my
bean "jpaRouterHelper.processGroupedExchanges" is called, I can process all
of the Exchanges using the Exchange.GROUPED_EXCHANGE.

I would like to do the same within a pollEnrich.  But there is no way to
tell pollEnrich to set the setCompletionFromBatchConsumer() so that I will
get all of the record.  I can set a timeout on the .pollEnrich(resourceUri,
timeout, aggregationStrategy).  The following is the route that I have:

from ("timer://jpaTimer?fixedRate=true&period=10s")	.pollEnrich (	
"jpa://com.cigna.upp.model.CustomerAccount?consumer.nativeQuery=" +		
"SELECT A, B, C, FROM MYTABLE WHERE CLNT_ACCT_NUM='5'" +		
"&consumeDelete=false" +		
"&consumer.resultClass=com.myapp.model.CustomerAccount",		new
GroupedExchangeAggregationStrategy())
.beanRef("jpaRouterHelper","processGroupedExchanges")
How would I get all of the records using the pollEnrich using the completion
from batch consumer?  Or should I be approaching this differently?

Any help is greatly appreciated.

thanks,
sunil.


--
View this message in context: http://camel.465427.n5.nabble.com/PollEnrich-JPA-setCompletionFromBatchConsumer-aggregator-tp5775895.html
Sent from the Camel Development mailing list archive at Nabble.com.
------=_Part_198622_378598793.1452091858464--