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(); }}?
