Question

ActiveMQ 如何获取服务器已有topic

• 你的回答被采纳后将获得：
• 系统奖励15（财富值+成长值）+难题奖励30（财富值+成长值）

Answer 1

package test;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import javax.jms.Session;

import org.apache.activemq.ActiveMQConnectionFactory;

public class ReceiverTest implements MessageListener{

public static void main(String[] args) {
// TODO Auto-generated method stub

new ReceiverTest().receiver();
}
public void receiver(){

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
Connection connection = null;
Session session = null;
try{
connection = connectionFactory.createConnection();
connection.start();
session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createTopic("myTopic");//和queue就这一点区别
//Destination destination = session.createQueue("myQueue");
MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(this);
}catch(Exception e){
e.printStackTrace();
try {
connection.close();
} catch (JMSException e1) {
e1.printStackTrace();
}
}

}
@Override
public void onMessage(Message message) {
ObjectMessage msg = (ObjectMessage)message;
try {
System.out.println("ReceiverMessage:"+msg.getObject());
} catch (JMSException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

}