Advertisement
Guest User

Untitled

a guest
May 28th, 2015
249
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 1.19 KB | None | 0 0
  1. package exemplocamel;
  2.  
  3. import javax.jms.ConnectionFactory;
  4.  
  5. import org.apache.activemq.ActiveMQConnectionFactory;
  6. import org.apache.camel.CamelContext;
  7. import org.apache.camel.builder.RouteBuilder;
  8. import org.apache.camel.component.jms.JmsComponent;
  9. import org.apache.camel.impl.DefaultCamelContext;
  10.  
  11. public final class RouterBasedMessage {
  12.  
  13.     public static void main(String[] args) throws Exception {
  14.         CamelContext context = new DefaultCamelContext();
  15.         ConnectionFactory factory = new ActiveMQConnectionFactory("admin", "admin", "failover:(tcp://localhost:61616)?timeout=1000");
  16.         context.addComponent("test-jms", JmsComponent.jmsComponentAutoAcknowledge(factory));
  17.        
  18.         context.addRoutes(new RouteBuilder() {
  19.             public void configure() {
  20.                 errorHandler(deadLetterChannel("mock:error"));
  21.                 from("test-jms:queue:origemQueue")
  22.                 .choice()
  23.                     .when(body().contains("queue1"))
  24.                         .to("test-jms:queue:queue1")
  25.                     .when(body().contains("queue2"))
  26.                         .to("test-jms:queue:queue2")
  27.                     .otherwise()
  28.                         .to("test-jms:queue:queueOther");
  29.             }
  30.         });
  31.         context.start();
  32.     }
  33. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement