<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>
properties
jms.connection.factory = tcp://localhost:61616
jms.queue = myQueue
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
public class JmsClientExample {
public static void main(String[] args) throws Exception {
CamelContext camelContext = new DefaultCamelContext();
String jmsConnectionFactory = "jms:queue:" + System.getProperty("jms.queue");
camelContext.addRoutes(new RouteBuilder() {
public void configure() {
from(jmsConnectionFactory)
.process(exchange -> {
String message = exchange.getIn().getBody(String.class);
System.out.println("Received message: " + message);
});
}
});
camelContext.start();
Thread.sleep(5000);
camelContext.stop();
}
}
