activemq 入门

这是一个activemq应用的简单示例代码,使用maven搭建的.适合刚刚开始学习activemq的程序员

package activemqDemo01;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Consumer {

	private static String brokerURL = “tcp://127.0.0.1:61616“;
	private static transient ConnectionFactory factory;
	private transient Connection connection;
	private transient Session session;
	
	public Consumer（） throws JMSException {
		factory = new ActiveMQConnectionFactory（brokerURL）;
		connection = factory.createConnection（）;
		connection.start（）;
		session = connection.createSession（false Session.AUTO_ACKNOWLEDGE）;
	}
	
	public void close（） throws JMSException {
		if（connection != null） {
			connection.close（）;
		}
	}
	
	public static void main（String[] args） throws JMSException {
		Consumer consumer = new Consumer（）;
		for（String stock : args） {
			Destination destination = consumer.getSession（）.createTopic（“STOCK.“ + stock）;
			MessageConsumer messageConsumer = consumer.getSession（）.createConsumer（destination）;
			messageConsumer.setMessageListener（new Listener（））;
		}
	}
	
	public Session getSession（） {
		return session;
	}
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       1434  2016-07-26 08:59  activemqDemo01\.classpath

     文件        566  2016-07-26 08:59  activemqDemo01\.project

     文件        243  2016-07-26 08:59  activemqDemo01\.settings\org.eclipse.jdt.core.prefs

     文件         90  2016-07-26 08:59  activemqDemo01\.settings\org.eclipse.m2e.core.prefs

     文件        861  2016-07-26 10:49  activemqDemo01\pom.xml

     文件       1284  2016-07-26 10:44  activemqDemo01\src\main\java\activemqDemo01\Consumer.java

     文件        707  2016-07-26 10:21  activemqDemo01\src\main\java\activemqDemo01\Listener.java

     文件       3312  2016-07-26 10:44  activemqDemo01\src\main\java\activemqDemo01\Publisher.java

     文件       2044  2016-07-26 10:44  activemqDemo01\target\classes\activemqDemo01\Consumer.class

     文件       1572  2016-07-26 10:35  activemqDemo01\target\classes\activemqDemo01\Listener.class

     文件       4418  2016-07-26 10:44  activemqDemo01\target\classes\activemqDemo01\Publisher.class

     目录          0  2016-07-26 10:14  activemqDemo01\src\main\java\activemqDemo01

     目录          0  2016-07-26 09:00  activemqDemo01\src\main\java

     目录          0  2016-07-26 08:59  activemqDemo01\src\main\resources

     目录          0  2016-07-26 08:59  activemqDemo01\src\test\java

     目录          0  2016-07-26 08:59  activemqDemo01\src\test\resources

     目录          0  2016-07-26 10:35  activemqDemo01\target\classes\activemqDemo01

     目录          0  2016-07-26 08:59  activemqDemo01\src\main

     目录          0  2016-07-26 08:59  activemqDemo01\src\test

     目录          0  2016-07-26 10:35  activemqDemo01\target\classes

     目录          0  2016-07-26 08:59  activemqDemo01\target\test-classes

     目录          0  2016-07-26 08:59  activemqDemo01\.settings

     目录          0  2016-07-26 08:59  activemqDemo01\src

     目录          0  2016-07-26 08:59  activemqDemo01\target

     目录          0  2016-07-26 08:59  activemqDemo01

----------- ---------  ---------- -----  ----

                16531                    25