时间戳

首页 > 解决方案 > 如果消息不包含消息选择器条件，为什么消费者会停止？

java - 如果消息不包含消息选择器条件，为什么消费者会停止？

问题描述

我最近与 jms 合作，我有这样一个问题。我必须收到消息 1) 所有消息 2) 仅在 type = 'LIQUID' 的情况下。我创建了两个消费者

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue(QUEUE_FOR_RECEIVED);
        QueueBrowser queueBrowser = session.createBrowser(queue);
        Enumeration enumeration = queueBrowser.getEnumeration();
        MessageConsumer consumer = session.createConsumer(queue);
        MessageConsumer liquidConsumer = session.createConsumer(queue, "type = 'LIQUID'");

首先收到所有消息，其次只有type = 'LIQUID'. 但是如果消息不包含，第二个消费者刚刚停止了应用程序type='LIQUID'

while (enumeration.hasMoreElements()) {
            ObjectMessage ss = (ObjectMessage) consumer.receive();
            System.out.println(ss.getObject());
            ObjectMessage msg = (ObjectMessage) liquidConsumer.receive(); // here consumer stopped if message doesn't contain type ='LIQUID'
            System.out.println(msg.getObject());
            enumeration.nextElement();
        }

如何改进？

标签： javajms

解决方案

应用程序停止的原因是因为javax.jms.MessageConsumer.receive()是阻塞调用。换句话说，它将阻止进一步的执行，直到返回结果。如果队列不包含任何与选择器匹配的消息，则调用javax.jms.MessageConsumer.receive()将无限期阻塞。这是预期的、记录在案的行为。

如果您不想在这里无限期阻止，您可以：

  1. 异步接收消息（例如使用javax.jms.MessageListener实现）
  2. 使用javax.jms.MessageConsumer.receive(int)并传递超时，receive以便在给定超时后没有收到消息时调用返回。
  3. 使用javax.jms.MessageConsumer.receiveNoWait()which 将尝试接收下一个匹配的消息，如果没有匹配的消息立即可用，它将返回。

推荐阅读