当队列中没有消息时，jms接收方法不会停止

Question

我已尝试从link 中提到的队列中接收消息。 队列可能包含多条消息。我想一口气读完。

问题：

我使用了下面给出的方法。但是当 3 分钟（180000 毫秒）后队列中没有消息时，我看不到控件被传递给 while 循环内的 else 部分。

因此，我无法到达 finally 块 tom 停止连接。

正如link 中给出的，当没有消息时，我应该会收到消息流结束控制消息。但我不明白。

由于 while 循环中的 else 部分没有被执行，并且 finally 块永远不会到达关闭连接

可能是什么问题？

方法：

import javax.naming.InitialContext;

import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.QueueSession;
import javax.jms.QueueReceiver;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;

public class Receiver
{
      @Resource(lookup = "jms/ConnectionFactory")
      private static QueueConnectionFactory connectionFactory;

      @Resource(lookup = "jms/Queue")
      private static Queue queue;

      public void readQueueMessages() {                                                                   
      try {
         // create a queue connection
         QueueConnection queueConn = connFactory.createQueueConnection();

         // create a queue session
         QueueSession queueSession = queueConn.createQueueSession(false,
         Session.AUTO_ACKNOWLEDGE);

        // create a queue receiver
         QueueReceiver queueReceiver = queueSession.createReceiver(queue);

         // start the connection
         queueConn.start();

         // receive a message
          while(true) {
          TextMessage message = (TextMessage) queueReceiver.receive(180000);
              if (message != null) { 
                      if (message instanceof TextMessage) {
                        / print the message
                          System.out.println("received: " + message.getText());
                      } else {
                             break; // when the end-of-message stream control is message is received, that cannnot be of Textmessage type. So the loop should terminate.
                      }
                 }
           }
        } catch(JMSException exp) {
           // Handle this exception
       } finally {      
            if(queueConn != null) {                                                     
                 // close the queue connection
                queueConn.close();
            }
       }

Answer 1

那个链接没有说“当没有消息时，我应该收到消息结束流控制消息。”，第7步说发送客户端需要
“发送一个空控制消息以指示消息流的结束： producer.send(session.createMessage());
发送一条没有指定类型的空消息是向消费者指示最终消息已到达的一种便捷方式。”
因此，除非您的消息生产者使用无类型的空消息（如示例）表示对话的最终消息，否则您的接收客户端无法按预期工作。