<dependency>
<groupId>javax.jms</groupId>
<artifactId>jms-api</artifactId>
<version>1.1</version>
</dependency>
import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;
public class JMSExample {
public static void main(String[] args) {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
}
}
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Session;
public class JMSExample {
public static void main(String[] args) {
try {
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
connection.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
}
import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
public class JMSExample {
public static void main(String[] args) {
try {
CamelContext context = new DefaultCamelContext();
ConnectionFactoryComponent jmsComponent = new ConnectionFactoryComponent();
jmsComponent.setConnectionFactory(connectionFactory);
context.addComponent("jms", jmsComponent);
context.addRoutes(new RouteBuilder() {
public void configure() {
from("direct:start")
.to("jms:queue:myQueue");
}
});
context.start();
ProducerTemplate template = context.createProducerTemplate();
template.sendBody("direct:start", "Hello, JMS!");
context.stop();
} catch (Exception e) {
e.printStackTrace();
}
}
}
