ACTIVEMQ JMS PUBLISH/SUBSCRIBE实例

--学习笔记，转自http://www.cnblogs.com/phoebus0501/archive/2011/02/25/1965276.html

?

一、MessagePublisher

?
二、MessageSubscriber
?
四、MyActiveMQDemo
package jms.activemq.myexample; import javax.jms.JMSException; public class MyActiveMQDemo {    public static void main(String[] args) throws InterruptedException, JMSException {        String url = "tcp://localhost:61616";        String user = null;        String password = null;        String query = "MyQueueA";        String topic = "TestTopic";                  //      new Thread(new MessageSender(query,url,user,password), "Name-Sender").start();//      new Thread(new MessageReceiver(query,url,user,password), "Name-Receiver1").start();//      new Thread(new MessageReceiver(query,url,user,password), "Name-Receiver2").start();//      new Thread(new MessageReceiver(query,url,user,password), "Name-Receiver3").start();//      new Thread(new MessageReceiver(query,url,user,password), "Name-Receiver4").start();//      new Thread(new MessageReceiver(query,url,user,password), "Name-Receiver5").start();                 new Thread(new MessageSubscriber(topic,url,user,password), "Name-Subscriber1").start();        new Thread(new MessageSubscriber(topic,url,user,password), "Name-Subscriber2").start();        new Thread(new MessageSubscriber(topic,url,user,password), "Name-Subscriber3").start();        new Thread(new MessageSubscriber(topic,url,user,password), "Name-Subscriber4").start();        new Thread(new MessageSubscriber(topic,url,user,password), "Name-Subscriber5").start();        Thread.sleep(5000);        new Thread(new MessagePublisher(topic,url,user,password), "Name-Publisher").start();        //new TopicPublisher().run();     }}
?