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;
	}
}

?屬性????????????大小?????日期????時(shí)間???名稱
-----------?---------??----------?-----??----

?????文件???????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