如题,怎么回事啊?我写的main方法测试的,第一遍能运行出来,第二次就不行了
public class MessageSendAndReceive {
public static void main(String[] args) throws JMSException {
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
"vm://localhost");
Connection connection = connectionFactory.createConnection();
connection.start();
Queue queue = new ActiveMQQueue("testQueue");
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
MessageProducer messageProducer = session.createProducer(queue);
messageProducer.send(session.createTextMessage("Message"));
MessageConsumer messageConsumer = session.createConsumer(queue);
messageConsumer.setMessageListener(new MessageListener() {
public void onMessage(Message msg) {
TextMessage message = (TextMessage) msg;
try {
System.out.println(message.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
});
这个只执行一次,第二次就没反应了,也不报错,要把MyEclipse关了在打开才能运行一次。。怎么回事啊