Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package exemplocamel;
- import javax.jms.ConnectionFactory;
- import org.apache.activemq.ActiveMQConnectionFactory;
- import org.apache.camel.CamelContext;
- import org.apache.camel.builder.RouteBuilder;
- import org.apache.camel.component.jms.JmsComponent;
- import org.apache.camel.impl.DefaultCamelContext;
- public final class RouterBasedMessage {
- public static void main(String[] args) throws Exception {
- CamelContext context = new DefaultCamelContext();
- ConnectionFactory factory = new ActiveMQConnectionFactory("admin", "admin", "failover:(tcp://localhost:61616)?timeout=1000");
- context.addComponent("test-jms", JmsComponent.jmsComponentAutoAcknowledge(factory));
- context.addRoutes(new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
- from("test-jms:queue:origemQueue")
- .choice()
- .when(body().contains("queue1"))
- .to("test-jms:queue:queue1")
- .when(body().contains("queue2"))
- .to("test-jms:queue:queue2")
- .otherwise()
- .to("test-jms:queue:queueOther");
- }
- });
- context.start();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement