MQQueueConnection.start 不会持续监听新消息

Question

您好，我正在尝试为 MQ 队列设置一个侦听器，该侦听器需要连续侦听队列并通过 onMessage 函数传递任何新消息。程序不应退出。 以下是我的程序的 sn-p。 在 MQQueueConnection.start 上，我在 onMessage 函数中遇到了问题，但是在从 MQ 消费了 1 条消息后，程序停止了。我希望程序永远运行并通过 onMessage 函数在队列中传递新消息。任何想法我做错了什么？ 使用 spring jms 类，它可以根据需要工作，尽管我不想在这里使用 spring。

public class MyListener implements MessageListener { 

    @Override
    public void onMessage(Message message)
    {
       try
       {
            handleMessage(message,session);
        }
       catch (Exception exx)
       {
            onHandleMessageException(message, exx);
        }
    }
}

public class TestListener
{
   public static void main(String[] args) {
      MyListener myListener = new MyListener();
      MQQueueConnectionFactory connFactory = new MQQueueConnectionFactory();
      //MyApplicationContext - custom class for loading MQ params
      MyApplicationContext obj=MyApplicationContext.getInstance();

      connFactory.setHostName(obj.getHost());
      connFactory.setPort(obj.getPort());
      connFactory.setQueueManager(obj.getQueueManagerName());
      connFactory.setChannel(obj.getChannel());
      connFactory.setTransportType(obj.getTransportType());

      MQQueueConnection connection=(MQQueueConnection) connFactory.createQueueConnection(obj.getMqUser(), obj.getMqPWD()) ;
      MQQueueSession session=(MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

      MQQueue queue = (MQQueue) session.createQueue("TEST.QUEUE");
      MQQueueReceiver qReceiver = (MQQueueReceiver) session.createReceiver(queue);
      qReceiver.setMessageListener(myListener);

      // expect to start a new thread, which will constantly listen for new messages 
      //on the queue and deliver it in onMessage function.
      //instead after receiving one message in onMessage, program exits
      connection.start(); 
   }
}

Answer 1

connection.start() 启动一个新线程，但该线程可能是daemon 线程，所以它在程序结束时结束。您很幸运收到了 1 条消息。

例如，在 main 的末尾尝试一个 Thread.sleep(60000)，然后监听器将在空中停留一分钟，您可能会收到更多消息。