package?com.tgb.activemq;

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?javax.jms.TextMessage;

import?org.apache.activemq.ActiveMQConnection;
import?org.apache.activemq.ActiveMQConnectionFactory;
/**
?*?消息的消費(fèi)者（接受者）
?*?@author?liang
?*
?*/
public?class?JMSConsumer?{

	private?static?final?String?USERNAME?=?ActiveMQConnection.DEFAULT_USER;//默認(rèn)連接用戶名
	private?static?final?String?PASSWORD?=?ActiveMQConnection.DEFAULT_PASSWORD;//默認(rèn)連接密碼
	private?static?final?String?BROKEURL?=?ActiveMQConnection.DEFAULT_BROKER_URL;//默認(rèn)連接地址
	
	public?static?void?main（String[]?args）?{
		ConnectionFactory?connectionFactory;//連接工廠
		Connection?connection?=?null;//連接
		
		Session?session;//會(huì)話?接受或者發(fā)送消息的線程
		Destination?destination;//消息的目的地
		
		MessageConsumer?messageConsumer;//消息的消費(fèi)者
		
		//實(shí)例化連接工廠
		connectionFactory?=?new?ActiveMQConnectionFactory（JMSConsumer.USERNAME?JMSConsumer.PASSWORD?JMSConsumer.BROKEURL）;
		
		try?{
			//通過(guò)連接工廠獲取連接
			connection?=?connectionFactory.createConnection（）;
			//啟動(dòng)連接
			connection.start（）;
			//創(chuàng)建session
			session?=?connection.createSession（false?Session.AUTO_ACKNOWLEDGE）;
			//創(chuàng)建一個(gè)連接HelloWorld的消息隊(duì)列
			destination?=?session.createQueue（“HelloWorld“）;
			//創(chuàng)建消息消費(fèi)者
			messageConsumer?=?session.createConsumer（destination）;
			
			while?（true）?{
				TextMessage?textMessage?=?（TextMessage）?messageConsumer.receive（100000）;
				if（textMessage?!=?null）{
					System.out.println（“收到的消息:“?+?textMessage.getText（））;
				}else?{
					break;
				}
			}
			
			
		}?catch?（JMSException?e）?{
			e.printStackTrace（）;
		}
		
	}
}

?屬性????????????大小?????日期????時(shí)間???名稱(chēng)
-----------?---------??----------?-----??----
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\
?????文件?????????599??2015-09-20?15:45??activeMQHelloWorld\.classpath
?????文件?????????394??2015-09-20?11:59??activeMQHelloWorld\.project
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\.settings\
?????文件?????????598??2015-09-20?11:59??activeMQHelloWorld\.settings\org.eclipse.jdt.core.prefs
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\bin\
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\bin\com\
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\bin\com\tgb\
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\bin\com\tgb\activemq\
?????文件????????2342??2015-09-20?17:20??activeMQHelloWorld\bin\com\tgb\activemq\JMSConsumer.class
?????文件????????2980??2015-09-20?17:20??activeMQHelloWorld\bin\com\tgb\activemq\JMSProducer.class
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\lib\
?????文件?????6590659??2015-06-02?21:54??activeMQHelloWorld\lib\activemq-all-5.11.1.jar
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\src\
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\src\com\
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\src\com\tgb\
?????目錄???????????0??2015-09-20?18:01??activeMQHelloWorld\src\com\tgb\activemq\
?????文件????????1864??2015-09-20?17:20??activeMQHelloWorld\src\com\tgb\activemq\JMSConsumer.java
?????文件????????2429??2015-09-20?17:20??activeMQHelloWorld\src\com\tgb\activemq\JMSProducer.java
?????文件??????????58??2018-02-03?23:20??下載地址.txt