I commented on the JIRA https://issues.apache.org/activemq/browse/CAMEL-170
but basically I've made 2 attempts at reproducing your issue; one using mock endpoints and the second using JMS queues; and both work fine for me. Any idea how to create a failing test case? the base class... https://svn.apache.org/repos/asf/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/issues/Issue170Test.java the jms based one... https://svn.apache.org/repos/asf/activemq/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsIssue170Test.java On 09/10/2007, Andreas Guther <[EMAIL PROTECTED]> wrote: > 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); > } > } > } > -- James ------- http://macstrac.blogspot.com/ Open Source SOA http://open.iona.com
