/**
?*?Licensed?to?the?Apache?Software?Foundation?（ASF）?under?one?or?more
?*?contributor?license?agreements.??See?the?NOTICE?file?distributed?with
?*?this?work?for?additional?information?regarding?copyright?ownership.
?*?The?ASF?licenses?this?file?to?You?under?the?Apache?License?Version?2.0
?*?（the?“License“）;?you?may?not?use?this?file?except?in?compliance?with
?*?the?License.??You?may?obtain?a?copy?of?the?License?at
?*
?*??????http://www.apache.org/licenses/LICENSE-2.0
?*
?*?Unless?required?by?applicable?law?or?agreed?to?in?writing?software
?*?distributed?under?the?License?is?distributed?on?an?“AS?IS“?BASIS
?*?WITHOUT?WARRANTIES?OR?CONDITIONS?OF?ANY?KIND?either?express?or?implied.
?*?See?the?License?for?the?specific?language?governing?permissions?and
?*?limitations?under?the?License.
?*/
package?example;

import?org.apache.qpid.jms.*;
import?javax.jms.*;

class?Listener?{

????public?static?void?main（String[]?args）?throws?JMSException?{

????????final?String?TOPIC_PREFIX?=?“topic://“;

????????String?user?=?env（“ACTIVEMQ_USER“?“admin“）;
????????String?password?=?env（“ACTIVEMQ_PASSWORD“?“password“）;
????????String?host?=?env（“ACTIVEMQ_HOST“?“localhost“）;
????????int?port?=?Integer.parseInt（env（“ACTIVEMQ_PORT“?“5672“））;

????????String?connectionURI?=?“amqp://“?+?host?+?“:“?+?port;
????????String?destinationName?=?arg（args?0?“topic://event“）;

????????JmsConnectionFactory?factory?=?new?JmsConnectionFactory（connectionURI）;

????????Connection?connection?=?factory.createConnection（user?password）;
????????connection.start（）;
????????Session?session?=?connection.createSession（false?Session.AUTO_ACKNOWLEDGE）;

????????Destination?destination?=?null;
????????if?（destinationName.startsWith（TOPIC_PREFIX））?{
????????????destination?=?session.createTopic（destinationName.substring（TOPIC_PREFIX.length（）））;
????????}?else?{
????????????destination?=?session.createQueue（destinationName）;
????????}

????????MessageConsumer?consumer?=?session.createConsumer（destination）;
????????long?start?=?System.currentTimeMillis（）;
????????long?count?=?1;
????????System.out.println（“Waiting?for?messages...“）;
????????while?（true）?{
????????????Message?msg?=?consumer.receive（）;
????????????if?（msg?instanceof?TextMessage）?{
????????????????String?body?=?（（TextMessage）?msg）.getText（）;
????????????????if?（“SHUTDOWN“.equals（body））?{
????????????????????long?diff?=?System.currentTimeMillis（）?-?start;
????????????????????System.out.println（String.format（“Received?%d?in?%.2f?seconds“?count?（1.0?*?diff?/?1000.0）））;
????????????????????connection.close（）;
????????????????????try?{
????????????????????????Thread.sleep（10）;
????????????????????}?catch?（Exception?e）?{}
????????????????????System.exit（1）;
????????????????}?else?{
????????????????????try?{
????????????????????????if?（count?!=?msg.getIntProperty（“id“））?{
????????????????????????????System.out.println（“mismatch:?“?+?count?+?“!=“?+?msg.getIntPrope

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\
?????目錄???????????0??2020-06-25?08:07??apache-activemq-5.16.0\conf\
?????目錄???????????0??2020-06-25?08:07??apache-activemq-5.16.0\data\
?????目錄???????????0??2020-06-25?08:07??apache-activemq-5.16.0\docs\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\java\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\java\src\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\java\src\main\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\java\src\main\java\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\java\src\main\java\example\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\amqp\python\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\conf\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\java\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\java\src\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\java\src\main\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\java\src\main\java\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\java\src\main\java\example\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\websocket\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\websocket\css\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\websocket\img\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\mqtt\websocket\js\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\jms-example-composite-destinations\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\jms-example-composite-destinations\src\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\jms-example-composite-destinations\src\main\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\jms-example-composite-destinations\src\main\java\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\jms-example-composite-destinations\src\main\java\example\
?????目錄???????????0??2020-06-25?08:08??apache-activemq-5.16.0\examples\openwire\advanced-scenarios\jms-example-composite-destinations\src\main\java\example\composite\
............此處省略671個文件信息