vwjugow

code2

Feb 1st, 2014
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.75 KB | None | 0 0
  1. CamelContext context = new DefaultCamelContext();
  2. ConnectionFactory connectionFactory = null;
  3. // connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:5445");
  4. // HornetQConnectionFactory c = new HornetQConnectionFactory();
  5. connectionFactory = HornetQJMSClient.createConnectionFactory("127.0.0.1", 5455);
  6. Thread.sleep(1000);
  7. context.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));
  8. context.addRoutes(new RouteBuilder() {
  9. public void configure() {
  10. from("jms:queue:someQueue").to("file://test");
  11. }
  12. });
  13. context.start();
  14. Thread.sleep(10000);
  15. context.stop();
Advertisement
Add Comment
Please, Sign In to add comment