程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> 更多編程語言 >> 編程綜合問答 >> connection-ActiveMQ只執行一次就不在執行了

connection-ActiveMQ只執行一次就不在執行了

編輯:編程綜合問答
ActiveMQ只執行一次就不在執行了

如題,怎麼回事啊?我寫的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關了在打開才能運行一次。。怎麼回事啊

最佳回答:


沒人啊。。。。求助啊。。。。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved