Sean,
I presented at CamelOne last week on how to handle exactly this kind of
scenarios with Camel and claimcheck. The code and slides are available
on github [1]. Please take a look and let me know if you have any questions.
Cheers,
Hadrian
[1] https://github.com/hzbarcea/camelone
On 06/21/2013 01:21 PM, Sean Beck wrote:
Could I create my own AggregationStrategy class that stores all the
messages and handles them appropriately? Or is there an easier way?
On Fri, Jun 21, 2013 at 9:19 AM, Sean Beck <seanmckayb...@gmail.com> wrote:
Thanks for the response.
The separate process is a program that puts two files together. Multiple
clients with their own SSIDs send over files, and there are 2 files that go
together for each set of data operated on by the client. As soon as the
files are received on my server the server sends a message containing the
file path, file name, SSID, and the "type" of the file. I want to use Camel
to detect when I get two messages for the same file name but each of a
different type (there are only two types) from the same SSID, then once I
get both messages start up the program that combines the two files.
So I know I want an aggregator that starts the process based off a
completion size of 2, but I don't know how everything works to really break
the problem down. 1) I need to figure out how I would execute the program
(which it looks like would be exec) 2) Have one aggregator that can put
messages together from different SSIDs.
On Fri, Jun 21, 2013 at 12:27 AM, Claus Ibsen <claus.ib...@gmail.com>wrote:
Hi
Can you be more specific with what you mean with separate process?
There is an exec to run an executable
http://camel.apache.org/exec
On Fri, Jun 21, 2013 at 1:19 AM, Sean Beck <seanmckayb...@gmail.com>
wrote:
So I have figured out how to gather messages based on my criteria. A
process needs to be started as soon as two messages have been received.
Currently I have:
from("jms:newFileQueue").aggregate(new
HeaderExpression("CamelFileName")).completionSize(2).to("triggerservice
to
process and merge files")
The portion I am unsure on is the very last call to to(). How would I
start
up a separate process once I get the necessary completionSize?
Thanks
--
Claus Ibsen
-----------------
www.camelone.org: The open source integration conference.
Red Hat, Inc.
FuseSource is now part of Red Hat
Email: cib...@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
