<dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-core</artifactId> <version>X.X.X</version> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-jms</artifactId> <version>X.X.X</version> </dependency> import org.apache.camel.builder.RouteBuilder; public class JmsRouteBuilder extends RouteBuilder { @Override public void configure() throws Exception { from("activemq:queue:inputQueue") .to("bean:messageProcessor") .to("activemq:queue:outputQueue"); } } camel.component.activemq.brokerURL=tcp://localhost:61616 camel.component.activemq.userName=admin camel.component.activemq.password=admin import org.apache.camel.CamelContext; import org.apache.camel.impl.DefaultCamelContext; public class MainApp { public static void main(String[] args) throws Exception { CamelContext context = new DefaultCamelContext(); context.addRoutes(new JmsRouteBuilder()); context.start(); Thread.sleep(5000); context.stop(); } }