Camel и ActiveMQ

Question

Я очень новый в мире верблюдов, поэтому я прошу вас о помощи. Позвольте мне сказать вам, что я хотел бы сделать: У меня есть этот базовый проект Camel автономный:

package maventest1; 


public class JmsToSql { 

private Main main; 

public static void main(String[] args) throws Exception { 
    JmsToSql example = new JmsToSql(); 
    example.boot(); 
} 

    public void boot() throws Exception { 
    main = new Main(); 
    main.enableHangupSupport(); 
    main.bind("foo", new MyBean()); 
    ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
    main.bind("test-jms",JmsComponent.jmsComponentAutoAcknowledge(connectionFactory)); 
    main.addRouteBuilder(new MyRouteBuilder()); 
    main.run(); 
} 

    private static class MyRouteBuilder extends RouteBuilder { 
    @Override 
    public void configure() throws Exception { 
     from("timer:foo?delay=2000") 
      .process(new Processor() { 
       public void process(Exchange exchange) throws Exception { 
         //NOT SURE THIS IS THE RIGHT WAY 
          from("test-jms:queue:order1") 
          .to("test-jms:queue:order2"); 
       } 
      }) 
      .beanRef("foo"); 
    } 
} 

public static class MyBean { 
    public void callMe() { 
     System.out.println("MyBean.calleMe method has been called"); 
    } 
    } 
} 

Все, что я хочу сделать, это прочитать все сообщения из очереди ActiveMQ и передать их в другую очередь. Кто-нибудь знает, как я могу это сделать? Заранее спасибо = D

Answer 1

Просто сделать маршрут из JMS в JMS

private static class MyRouteBuilder extends RouteBuilder { 
    @Override 
    public void configure() throws Exception { 
     from("test-jms:queue:order1") 
      .to("test-jms:queue:order2"); 
    } 

Как вы новичок в Camel, я рекомендую также прочитать эту статью

• http://java.dzone.com/articles/open-source-integration-apache

И если вы хотите иметь отличную документацию и учебные пособия, тогда возьмите одну из книг Camel

• http://camel.apache.org/books