You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Marco Bettiol <ja...@gmail.com> on 2010/11/28 21:39:34 UTC
Problem with my first aggregate Route (newbie to Camel)
Hi guys,
I'm new to apache Camel. It sound really great.
I was trying to build my first application. I got a file with entries of
different type and I want to generate a new file with only a subset of the
lines (in the final version I will have to build up a POJO and send it using
web-service).
The problem is that when I try to aggregate the lines the output file
contains only the last not filtered row
Thank you for your support :)
Marco
Here is the code
-------------------------------
public class Test {
private DefaultCamelContext camel;
public static void main(String[] args) throws Exception{
new Test();
}
public Test() throws Exception{
camel = new DefaultCamelContext();
camel.addRoutes(new RouteBuilder() {
public void configure() { from(
"file:/Users/marcobettiol/IES/data?noop=true")
.split(body().tokenize("\n"), new
TVCEOrderAggregateStrategy()).filter(newPredicate() {
@Override
public boolean matches(Exchange exchange) {
String content =exchange.getIn().getBody(String.class);
if(content.startsWith("vnboltes") || content.startsWith("vnbolcas"))
return true;
return true;
//keep everything for test
}
})
.to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
}
});
camel.start();
Thread.sleep(5000);
camel.stop();
}
}
--------------------------
public class TVCEOrderAggregateStrategy implements AggregationStrategy{
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
if (oldExchange == null) {
return newExchange;
}
String oldBody = oldExchange.getIn().getBody(String.class);
String newBody = newExchange.getIn().getBody(String.class);
String concatBody = oldBody.concat(newBody);
oldExchange.getIn().setBody(concatBody);
return oldExchange;
}
}
Re: Problem with my first aggregate Route (newbie to Camel)
Posted by Claus Ibsen <cl...@gmail.com>.
On Mon, Nov 29, 2010 at 1:48 PM, Marco Bettiol <ja...@gmail.com> wrote:
> Claus... It's me again. Sorry.
> I moved the filter logic to the AggregateStrategy
> I tried some variants to insert "end()" such as:
>
>
> from("file:/Users/marcobettiol/IES/data?noop=true")
>
> .split(body().tokenize("\n"), new TVCEOrderAggregateStrategy())
>
> .end()
>
> .to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
>
>
> but i get Route has no child Exception
>
> --------------
>
> failed to create route route1 at: >>> Split[{tokenize(body,
>
> )} -> []] <<< in route:
> Route[[From[file:/Users/marcobettiol/IES/data?noop=true]] ->... because of
> Definition has no children on Split[{tokenize(body,
>
> )} -> []]
>
>
Ah yeah thats because usually your splitter you want to do something
with each splitted message.
So just add an empty processor, or send it to a log etc.
.to("log:dummy")
>
>
> 2010/11/29 Claus Ibsen <cl...@gmail.com>
>
>> On Mon, Nov 29, 2010 at 10:26 AM, Marco Bettiol <ja...@gmail.com>
>> wrote:
>> > I'm using 2.5.0.
>> > Ok I will try with your solution and let you know. :)
>> > P.S.
>> > Just for knowledge... Is my code right?
>> >
>>
>> No the filter should not be in the split. Camel will always invoke the
>> AggregationStrategy for each splitted message.
>> So you should implement the logic here if you want to skip certain
>> messages.
>>
>> And you should in essence use .end() in the route to denote when the
>> filter / splitter ends.
>>
>> from
>> split
>> filter
>> end
>> end
>> to
>>
>> But you logic could simply be
>>
>> from
>> split
>> end
>> to
>>
>>
>>
>> > 2010/11/29 Claus Ibsen <cl...@gmail.com>
>> >
>> >> Hi
>> >>
>> >> What version of Camel are you using?
>> >>
>> >> And you can also do your filter logic in the aggregator. Just return
>> >> oldExchange if the newExchange should be skipped.
>> >>
>> >>
>> >> On Sun, Nov 28, 2010 at 9:39 PM, Marco Bettiol <ja...@gmail.com>
>> >> wrote:
>> >> > Hi guys,
>> >> >
>> >> > I'm new to apache Camel. It sound really great.
>> >> >
>> >> > I was trying to build my first application. I got a file with entries
>> of
>> >> > different type and I want to generate a new file with only a subset of
>> >> the
>> >> > lines (in the final version I will have to build up a POJO and send it
>> >> using
>> >> > web-service).
>> >> >
>> >> >
>> >> > The problem is that when I try to aggregate the lines the output file
>> >> > contains only the last not filtered row
>> >> >
>> >> >
>> >> > Thank you for your support :)
>> >> >
>> >> > Marco
>> >> >
>> >> >
>> >> >
>> >> > Here is the code
>> >> >
>> >> > -------------------------------
>> >> >
>> >> > public class Test {
>> >> >
>> >> > private DefaultCamelContext camel;
>> >> >
>> >> > public static void main(String[] args) throws Exception{
>> >> >
>> >> > new Test();
>> >> >
>> >> > }
>> >> >
>> >> > public Test() throws Exception{
>> >> >
>> >> > camel = new DefaultCamelContext();
>> >> >
>> >> > camel.addRoutes(new RouteBuilder() {
>> >> >
>> >> > public void configure() { from(
>> >> > "file:/Users/marcobettiol/IES/data?noop=true")
>> >> >
>> >> > .split(body().tokenize("\n"), new
>> >> > TVCEOrderAggregateStrategy()).filter(newPredicate() {
>> >> >
>> >> > @Override
>> >> >
>> >> > public boolean matches(Exchange exchange) {
>> >> >
>> >> > String content =exchange.getIn().getBody(String.class);
>> >> >
>> >> > if(content.startsWith("vnboltes") || content.startsWith("vnbolcas"))
>> >> >
>> >> > return true;
>> >> >
>> >> > return true;
>> >> >
>> >> > //keep everything for test
>> >> >
>> >> > }
>> >> >
>> >> > })
>> >> >
>> >> > .to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
>> >> >
>> >> > }
>> >> >
>> >> > });
>> >> >
>> >> > camel.start();
>> >> >
>> >> > Thread.sleep(5000);
>> >> >
>> >> > camel.stop();
>> >> >
>> >> > }
>> >> >
>> >> >
>> >> > }
>> >> >
>> >> > --------------------------
>> >> >
>> >> > public class TVCEOrderAggregateStrategy implements
>> AggregationStrategy{
>> >> >
>> >> > public Exchange aggregate(Exchange oldExchange, Exchange
>> newExchange)
>> >> {
>> >> >
>> >> > if (oldExchange == null) {
>> >> >
>> >> > return newExchange;
>> >> >
>> >> > }
>> >> >
>> >> > String oldBody = oldExchange.getIn().getBody(String.class);
>> >> >
>> >> > String newBody = newExchange.getIn().getBody(String.class);
>> >> >
>> >> > String concatBody = oldBody.concat(newBody);
>> >> >
>> >> > oldExchange.getIn().setBody(concatBody);
>> >> >
>> >> > return oldExchange;
>> >> >
>> >> >
>> >> > }
>> >> >
>> >> >
>> >> > }
>> >> >
>> >>
>> >>
>> >>
>> >> --
>> >> Claus Ibsen
>> >> -----------------
>> >> FuseSource
>> >> Email: cibsen@fusesource.com
>> >> Web: http://fusesource.com
>> >> Twitter: davsclaus
>> >> Blog: http://davsclaus.blogspot.com/
>> >> Author of Camel in Action: http://www.manning.com/ibsen/
>> >>
>> >
>>
>>
>>
>> --
>> Claus Ibsen
>> -----------------
>> FuseSource
>> Email: cibsen@fusesource.com
>> Web: http://fusesource.com
>> Twitter: davsclaus
>> Blog: http://davsclaus.blogspot.com/
>> Author of Camel in Action: http://www.manning.com/ibsen/
>>
>
--
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Re: Problem with my first aggregate Route (newbie to Camel)
Posted by Marco Bettiol <ja...@gmail.com>.
Claus... It's me again. Sorry.
I moved the filter logic to the AggregateStrategy
I tried some variants to insert "end()" such as:
from("file:/Users/marcobettiol/IES/data?noop=true")
.split(body().tokenize("\n"), new TVCEOrderAggregateStrategy())
.end()
.to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
but i get Route has no child Exception
--------------
failed to create route route1 at: >>> Split[{tokenize(body,
)} -> []] <<< in route:
Route[[From[file:/Users/marcobettiol/IES/data?noop=true]] ->... because of
Definition has no children on Split[{tokenize(body,
)} -> []]
2010/11/29 Claus Ibsen <cl...@gmail.com>
> On Mon, Nov 29, 2010 at 10:26 AM, Marco Bettiol <ja...@gmail.com>
> wrote:
> > I'm using 2.5.0.
> > Ok I will try with your solution and let you know. :)
> > P.S.
> > Just for knowledge... Is my code right?
> >
>
> No the filter should not be in the split. Camel will always invoke the
> AggregationStrategy for each splitted message.
> So you should implement the logic here if you want to skip certain
> messages.
>
> And you should in essence use .end() in the route to denote when the
> filter / splitter ends.
>
> from
> split
> filter
> end
> end
> to
>
> But you logic could simply be
>
> from
> split
> end
> to
>
>
>
> > 2010/11/29 Claus Ibsen <cl...@gmail.com>
> >
> >> Hi
> >>
> >> What version of Camel are you using?
> >>
> >> And you can also do your filter logic in the aggregator. Just return
> >> oldExchange if the newExchange should be skipped.
> >>
> >>
> >> On Sun, Nov 28, 2010 at 9:39 PM, Marco Bettiol <ja...@gmail.com>
> >> wrote:
> >> > Hi guys,
> >> >
> >> > I'm new to apache Camel. It sound really great.
> >> >
> >> > I was trying to build my first application. I got a file with entries
> of
> >> > different type and I want to generate a new file with only a subset of
> >> the
> >> > lines (in the final version I will have to build up a POJO and send it
> >> using
> >> > web-service).
> >> >
> >> >
> >> > The problem is that when I try to aggregate the lines the output file
> >> > contains only the last not filtered row
> >> >
> >> >
> >> > Thank you for your support :)
> >> >
> >> > Marco
> >> >
> >> >
> >> >
> >> > Here is the code
> >> >
> >> > -------------------------------
> >> >
> >> > public class Test {
> >> >
> >> > private DefaultCamelContext camel;
> >> >
> >> > public static void main(String[] args) throws Exception{
> >> >
> >> > new Test();
> >> >
> >> > }
> >> >
> >> > public Test() throws Exception{
> >> >
> >> > camel = new DefaultCamelContext();
> >> >
> >> > camel.addRoutes(new RouteBuilder() {
> >> >
> >> > public void configure() { from(
> >> > "file:/Users/marcobettiol/IES/data?noop=true")
> >> >
> >> > .split(body().tokenize("\n"), new
> >> > TVCEOrderAggregateStrategy()).filter(newPredicate() {
> >> >
> >> > @Override
> >> >
> >> > public boolean matches(Exchange exchange) {
> >> >
> >> > String content =exchange.getIn().getBody(String.class);
> >> >
> >> > if(content.startsWith("vnboltes") || content.startsWith("vnbolcas"))
> >> >
> >> > return true;
> >> >
> >> > return true;
> >> >
> >> > //keep everything for test
> >> >
> >> > }
> >> >
> >> > })
> >> >
> >> > .to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
> >> >
> >> > }
> >> >
> >> > });
> >> >
> >> > camel.start();
> >> >
> >> > Thread.sleep(5000);
> >> >
> >> > camel.stop();
> >> >
> >> > }
> >> >
> >> >
> >> > }
> >> >
> >> > --------------------------
> >> >
> >> > public class TVCEOrderAggregateStrategy implements
> AggregationStrategy{
> >> >
> >> > public Exchange aggregate(Exchange oldExchange, Exchange
> newExchange)
> >> {
> >> >
> >> > if (oldExchange == null) {
> >> >
> >> > return newExchange;
> >> >
> >> > }
> >> >
> >> > String oldBody = oldExchange.getIn().getBody(String.class);
> >> >
> >> > String newBody = newExchange.getIn().getBody(String.class);
> >> >
> >> > String concatBody = oldBody.concat(newBody);
> >> >
> >> > oldExchange.getIn().setBody(concatBody);
> >> >
> >> > return oldExchange;
> >> >
> >> >
> >> > }
> >> >
> >> >
> >> > }
> >> >
> >>
> >>
> >>
> >> --
> >> Claus Ibsen
> >> -----------------
> >> FuseSource
> >> Email: cibsen@fusesource.com
> >> Web: http://fusesource.com
> >> Twitter: davsclaus
> >> Blog: http://davsclaus.blogspot.com/
> >> Author of Camel in Action: http://www.manning.com/ibsen/
> >>
> >
>
>
>
> --
> Claus Ibsen
> -----------------
> FuseSource
> Email: cibsen@fusesource.com
> Web: http://fusesource.com
> Twitter: davsclaus
> Blog: http://davsclaus.blogspot.com/
> Author of Camel in Action: http://www.manning.com/ibsen/
>
Re: Problem with my first aggregate Route (newbie to Camel)
Posted by Claus Ibsen <cl...@gmail.com>.
On Mon, Nov 29, 2010 at 10:26 AM, Marco Bettiol <ja...@gmail.com> wrote:
> I'm using 2.5.0.
> Ok I will try with your solution and let you know. :)
> P.S.
> Just for knowledge... Is my code right?
>
No the filter should not be in the split. Camel will always invoke the
AggregationStrategy for each splitted message.
So you should implement the logic here if you want to skip certain messages.
And you should in essence use .end() in the route to denote when the
filter / splitter ends.
from
split
filter
end
end
to
But you logic could simply be
from
split
end
to
> 2010/11/29 Claus Ibsen <cl...@gmail.com>
>
>> Hi
>>
>> What version of Camel are you using?
>>
>> And you can also do your filter logic in the aggregator. Just return
>> oldExchange if the newExchange should be skipped.
>>
>>
>> On Sun, Nov 28, 2010 at 9:39 PM, Marco Bettiol <ja...@gmail.com>
>> wrote:
>> > Hi guys,
>> >
>> > I'm new to apache Camel. It sound really great.
>> >
>> > I was trying to build my first application. I got a file with entries of
>> > different type and I want to generate a new file with only a subset of
>> the
>> > lines (in the final version I will have to build up a POJO and send it
>> using
>> > web-service).
>> >
>> >
>> > The problem is that when I try to aggregate the lines the output file
>> > contains only the last not filtered row
>> >
>> >
>> > Thank you for your support :)
>> >
>> > Marco
>> >
>> >
>> >
>> > Here is the code
>> >
>> > -------------------------------
>> >
>> > public class Test {
>> >
>> > private DefaultCamelContext camel;
>> >
>> > public static void main(String[] args) throws Exception{
>> >
>> > new Test();
>> >
>> > }
>> >
>> > public Test() throws Exception{
>> >
>> > camel = new DefaultCamelContext();
>> >
>> > camel.addRoutes(new RouteBuilder() {
>> >
>> > public void configure() { from(
>> > "file:/Users/marcobettiol/IES/data?noop=true")
>> >
>> > .split(body().tokenize("\n"), new
>> > TVCEOrderAggregateStrategy()).filter(newPredicate() {
>> >
>> > @Override
>> >
>> > public boolean matches(Exchange exchange) {
>> >
>> > String content =exchange.getIn().getBody(String.class);
>> >
>> > if(content.startsWith("vnboltes") || content.startsWith("vnbolcas"))
>> >
>> > return true;
>> >
>> > return true;
>> >
>> > //keep everything for test
>> >
>> > }
>> >
>> > })
>> >
>> > .to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
>> >
>> > }
>> >
>> > });
>> >
>> > camel.start();
>> >
>> > Thread.sleep(5000);
>> >
>> > camel.stop();
>> >
>> > }
>> >
>> >
>> > }
>> >
>> > --------------------------
>> >
>> > public class TVCEOrderAggregateStrategy implements AggregationStrategy{
>> >
>> > public Exchange aggregate(Exchange oldExchange, Exchange newExchange)
>> {
>> >
>> > if (oldExchange == null) {
>> >
>> > return newExchange;
>> >
>> > }
>> >
>> > String oldBody = oldExchange.getIn().getBody(String.class);
>> >
>> > String newBody = newExchange.getIn().getBody(String.class);
>> >
>> > String concatBody = oldBody.concat(newBody);
>> >
>> > oldExchange.getIn().setBody(concatBody);
>> >
>> > return oldExchange;
>> >
>> >
>> > }
>> >
>> >
>> > }
>> >
>>
>>
>>
>> --
>> Claus Ibsen
>> -----------------
>> FuseSource
>> Email: cibsen@fusesource.com
>> Web: http://fusesource.com
>> Twitter: davsclaus
>> Blog: http://davsclaus.blogspot.com/
>> Author of Camel in Action: http://www.manning.com/ibsen/
>>
>
--
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
Re: Problem with my first aggregate Route (newbie to Camel)
Posted by Marco Bettiol <ja...@gmail.com>.
I'm using 2.5.0.
Ok I will try with your solution and let you know. :)
P.S.
Just for knowledge... Is my code right?
2010/11/29 Claus Ibsen <cl...@gmail.com>
> Hi
>
> What version of Camel are you using?
>
> And you can also do your filter logic in the aggregator. Just return
> oldExchange if the newExchange should be skipped.
>
>
> On Sun, Nov 28, 2010 at 9:39 PM, Marco Bettiol <ja...@gmail.com>
> wrote:
> > Hi guys,
> >
> > I'm new to apache Camel. It sound really great.
> >
> > I was trying to build my first application. I got a file with entries of
> > different type and I want to generate a new file with only a subset of
> the
> > lines (in the final version I will have to build up a POJO and send it
> using
> > web-service).
> >
> >
> > The problem is that when I try to aggregate the lines the output file
> > contains only the last not filtered row
> >
> >
> > Thank you for your support :)
> >
> > Marco
> >
> >
> >
> > Here is the code
> >
> > -------------------------------
> >
> > public class Test {
> >
> > private DefaultCamelContext camel;
> >
> > public static void main(String[] args) throws Exception{
> >
> > new Test();
> >
> > }
> >
> > public Test() throws Exception{
> >
> > camel = new DefaultCamelContext();
> >
> > camel.addRoutes(new RouteBuilder() {
> >
> > public void configure() { from(
> > "file:/Users/marcobettiol/IES/data?noop=true")
> >
> > .split(body().tokenize("\n"), new
> > TVCEOrderAggregateStrategy()).filter(newPredicate() {
> >
> > @Override
> >
> > public boolean matches(Exchange exchange) {
> >
> > String content =exchange.getIn().getBody(String.class);
> >
> > if(content.startsWith("vnboltes") || content.startsWith("vnbolcas"))
> >
> > return true;
> >
> > return true;
> >
> > //keep everything for test
> >
> > }
> >
> > })
> >
> > .to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
> >
> > }
> >
> > });
> >
> > camel.start();
> >
> > Thread.sleep(5000);
> >
> > camel.stop();
> >
> > }
> >
> >
> > }
> >
> > --------------------------
> >
> > public class TVCEOrderAggregateStrategy implements AggregationStrategy{
> >
> > public Exchange aggregate(Exchange oldExchange, Exchange newExchange)
> {
> >
> > if (oldExchange == null) {
> >
> > return newExchange;
> >
> > }
> >
> > String oldBody = oldExchange.getIn().getBody(String.class);
> >
> > String newBody = newExchange.getIn().getBody(String.class);
> >
> > String concatBody = oldBody.concat(newBody);
> >
> > oldExchange.getIn().setBody(concatBody);
> >
> > return oldExchange;
> >
> >
> > }
> >
> >
> > }
> >
>
>
>
> --
> Claus Ibsen
> -----------------
> FuseSource
> Email: cibsen@fusesource.com
> Web: http://fusesource.com
> Twitter: davsclaus
> Blog: http://davsclaus.blogspot.com/
> Author of Camel in Action: http://www.manning.com/ibsen/
>
Re: Problem with my first aggregate Route (newbie to Camel)
Posted by Claus Ibsen <cl...@gmail.com>.
Hi
What version of Camel are you using?
And you can also do your filter logic in the aggregator. Just return
oldExchange if the newExchange should be skipped.
On Sun, Nov 28, 2010 at 9:39 PM, Marco Bettiol <ja...@gmail.com> wrote:
> Hi guys,
>
> I'm new to apache Camel. It sound really great.
>
> I was trying to build my first application. I got a file with entries of
> different type and I want to generate a new file with only a subset of the
> lines (in the final version I will have to build up a POJO and send it using
> web-service).
>
>
> The problem is that when I try to aggregate the lines the output file
> contains only the last not filtered row
>
>
> Thank you for your support :)
>
> Marco
>
>
>
> Here is the code
>
> -------------------------------
>
> public class Test {
>
> private DefaultCamelContext camel;
>
> public static void main(String[] args) throws Exception{
>
> new Test();
>
> }
>
> public Test() throws Exception{
>
> camel = new DefaultCamelContext();
>
> camel.addRoutes(new RouteBuilder() {
>
> public void configure() { from(
> "file:/Users/marcobettiol/IES/data?noop=true")
>
> .split(body().tokenize("\n"), new
> TVCEOrderAggregateStrategy()).filter(newPredicate() {
>
> @Override
>
> public boolean matches(Exchange exchange) {
>
> String content =exchange.getIn().getBody(String.class);
>
> if(content.startsWith("vnboltes") || content.startsWith("vnbolcas"))
>
> return true;
>
> return true;
>
> //keep everything for test
>
> }
>
> })
>
> .to("file:/Users/marcobettiol/IES/copy?autoCreate=true");
>
> }
>
> });
>
> camel.start();
>
> Thread.sleep(5000);
>
> camel.stop();
>
> }
>
>
> }
>
> --------------------------
>
> public class TVCEOrderAggregateStrategy implements AggregationStrategy{
>
> public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
>
> if (oldExchange == null) {
>
> return newExchange;
>
> }
>
> String oldBody = oldExchange.getIn().getBody(String.class);
>
> String newBody = newExchange.getIn().getBody(String.class);
>
> String concatBody = oldBody.concat(newBody);
>
> oldExchange.getIn().setBody(concatBody);
>
> return oldExchange;
>
>
> }
>
>
> }
>
--
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/