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个回答

没人啊。。。。求助啊。。。。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问