Hello,
I am working on creating a simple route using camel and java. I have
the following code:
public class CamelMain {
public static void main(String[] args) throws Exception {
CamelContext context = new DefaultCamelContext();
ConnectionFactory connectionFactory = new
ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
context.addComponent("test-jms",
JmsComponent.jmsComponent(connectionFactory));
context.addRoutes(new RouteBuilder() {
public void configure() {
from("test-jms:queue:example.A").to("test-jms:queue:example.B");
}
});
context.start();
}
}
When I go to the camel admin page (http://127.0.0.1:8161/camel), it
shows that the route has been created. The problem is that when I try
and send a message to the "example.A" queue, it never seems to get
picked up by the MessageListener that is listening to the "example.B"
queue. The sender and listener are running in separate JVM's if that
makes a difference.
Where am I going wrong?
