camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hadrian Zbarcea <hzbar...@gmail.com>
Subject Re: How to start a process with Camel?
Date Fri, 21 Jun 2013 18:24:59 GMT
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 <seanmckaybeck@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.ibsen@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 <seanmckaybeck@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: cibsen@redhat.com
>>> Web: http://fusesource.com
>>> Twitter: davsclaus
>>> Blog: http://davsclaus.com
>>> Author of Camel in Action: http://www.manning.com/ibsen
>>>
>>
>>
>

Mime
View raw message