Hi,
There is something I do not understand in the Pipeline processor.
Let's consider the following route declaration :
from("seda:pipeline").pipeline("seda:rs1","seda:rs2","seda:rs3");
ChangeBody cb = new ChangeBody();
from("seda:rs1").bean(cb);
from("seda:rs2").bean(cb);
from("seda:rs3").bean(cb).to("log:pipeline?showAll=true");
With ChangeBody, a simple bean to concat twice body.
static public class ChangeBody{
public String change(@Body String body) throws Exception {
return body + body;
}
}
For example, if I inject the "a" body message, I would expect to have
"aaaaaaaa"(2*2*2) in the log message, but I've just got "aa".
What have I miss ? (I'm using 1.6.0 version since I use Camel in SMX 3.3).
Thanks all.
Raphaël