Either I am getting something wrong or the current 1.2.0 version has some problems. My observation is that the RouteBuilder from the provided spring example does only write into the last queue of the given to list.
See my altered MyRouteBuilder class at the end of this message from the following location: C:\dev\svn.apache.org\repos\asf\activemq\camel\tags\camel-1.2.0\examples \camel-example-spring>svn info Path: . URL: https://svn.apache.org/repos/asf/activemq/camel/tags/camel-1.2.0/example s/camel-example-spring Repository Root: https://svn.apache.org/repos/asf Repository UUID: 13f79535-47bb-0310-9956-ffa450edef68 Revision: 582255 Node Kind: directory Schedule: normal Last Changed Author: chirino Last Changed Rev: 581980 Last Changed Date: 2007-10-04 11:24:52 -0700 (Thu, 04 Oct 2007) Please let me know if you think this is a bug and I will file a Jira issue. I have no unit tests for this. I was running against a local ActiveMQ 4.1.1 broker with tcp instead of the vm protocol as it comes in the example. public class MyRouteBuilder extends RouteBuilder { public static final String Q1 = "jms:test.MyQueue.ONE-1"; public static final String Q2 = "jms:test.Number.2"; public static final String Q3 = "jms:test.Number.3"; /** * Allow this route to be run as an application * * @param args */ public static void main(String[] args) { new Main().run(args); } public void configure() { System.out.println("**** Configuring ****"); // lets populate the message queue with some messages from("file:src/data?noop=true").to(Q1); //from(Q1).to("file://target/test?noop=true"); // works fine and writes into file system //from(Q1).to(Q2); // works also fine, writes into Q2 //from(Q1).to("file://target/test?noop=true", Q2); // writes to Q2 but not to file //from(Q1).to(Q2, "file://target/test?noop=true"); // writes to file but not to Q2 from(Q1).to(Q2, Q3); // write to Q3 but not to Q2 // set up a listener on the file component from("file://target/test?noop=true"). bean(new SomeBean()); } public static class SomeBean { public void someMethod(String body) { System.out.println("Received: " + body); } } }
