JMS入门实例

package test;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;

public class jms {
?public static void main(String[] args) {
??// 创建连接工厂
??ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
??Connection conn = null;
??Queue queue = new ActiveMQQueue("testQueue");
??try {
???// 创建连接
???conn = factory.createConnection();
???conn.start();
???// 创建Session
???Session session = conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
???// 创建Message
???Message message = session.createTextMessage("Hello World!");
???// 创建消息生产者
???MessageProducer producer = session.createProducer(queue);
???// 发送消息
???producer.send(message);
???// 创建消息接收
???MessageConsumer consumer = session.createConsumer(queue);
???Message receiver = consumer.receive();
???System.out.println(((TextMessage) receiver).getText());
??} catch (JMSException e) {
???e.printStackTrace();
??}

?}
}