n inactivity, and the latter is triggered in
> fixed schedules after a given interval elapsed.
> And the former is based on per correlated key, and the latter is
> general and for all.
>
> See details at
> http://camel.apache.org/aggregator2
>
>
>
> On Wed, Jul 10, 201
If i set the timeout for one minute in an aggregator will the timer restart
every time a new message comes over? Thanks
Just include every possible jar file that comes with ActiveMQ. Some of the ones
you include may depend on others that you dont include
krishnagjs wrote:
>I have developed a simple camel route with ActiveMQ endpoint. The pom
>file
>is:
>
>http://maven.apache.org/POM/4.0.0";
>xmlns:xsi="http://www
pache Camel: https://www.apache.org/foundation/
> Apache Member: https://www.apache.org/foundation/members.html
>
> https://www.linkedin.com/pub/christian-mueller/11/551/642
>
>
> On Thu, Jun 27, 2013 at 11:35 PM, Sean Beck
> wrote:
>
> > So I send messages with a cus
So I send messages with a custom header called "uuid" and a camel program
that aggregates based on this header. I know that the value gets set in my
messages. However when I pull a message from the queue in my camel program
and use newExchange.getProperty("uuid") and cast it to a string, I get null
So I have some code I've tried writing and I think it solves the problem. I
just want to check to make sure I'm not goofing anything up. Also, in
AggregationStrategy.aggregate() what exchange should I return from what I
have?
public static void main(String args[]) {
CamelContext c = new D
omeone
said to use a GroupedExchange or something as well where I correlate on
clientID and fileName. I'm not really sure how that works thoughAm I on
the right track?
On Fri, Jun 21, 2013 at 1:16 PM, Sean Beck wrote:
> Everything installed fine for camelone but I ran mvn camel:run a
Everything installed fine for camelone but I ran mvn camel:run and it seems
to have gotten stuck after first [INFO]
On Fri, Jun 21, 2013 at 12:27 PM, Sean Beck wrote:
> Thanks for the response! I'll look now and let you know
>
>
> On Fri, Jun 21, 2013 at 12:24 PM, Hadr
; 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
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 wrote:
> Thanks for the response.
>
> The separate process is a program that puts two files together.
egator that can put
messages together from different SSIDs.
On Fri, Jun 21, 2013 at 12:27 AM, Claus Ibsen 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
>
>
>
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")
mq (either 'native' or http REST) which in turn talks to
> camel.
>
>
> On 20 June 2013 21:05, Sean Beck wrote:
>
> > Hi all,
> >
> > I am new to Camel and was directed to use it for some functionality I
> want
> > to build into my code.
> >
Hi all,
I am new to Camel and was directed to use it for some functionality I want
to build into my code.
So I am sending files over to a server and there are two files with the
same name but of a different "type" that are merged together on the server
side. As soon as a file is received I send a
14 matches
Mail list logo
