Thanks for the response! I'll look now and let you know
On Fri, Jun 21, 2013 at 12:24 PM, Hadrian Zbarcea <hzbar...@gmail.com>wrote: > 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<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 >>>> >>>> >>> >>> >>
