JMS 消息选择器不工作

Question

我需要根据消息选择器过滤消息，但使用 messageSelector 的消费者似乎没有过滤任何消息。

我写了下面的代码

ActiveMQUtil

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class ActiveMQUtil {
   private ConnectionFactory connectionFactory = null;
    private Connection connection =null;
    private Session session =null;
    private MessageProducer producer = null;
    private MessageConsumer consumer = null;
    private Queue destination = null;
    private MessageConsumer consumerWithSelector;

    public static void main(String []arg) throws JMSException {
        ActiveMQUtil activeMQUtil = new ActiveMQUtil();
        activeMQUtil.initialize();

        activeMQUtil.produceMessage(25000);
        activeMQUtil.consumeMessage();

    }

    private void consumeMessage() throws JMSException {
        Message message = consumerWithSelector.receive(100); // this does not select any message
        //Message message = consumer.receive(100); // This properly received the message and I can see the message
        if(null!=message && message.propertyExists("msgID")){
            System.out.println("Consumed message with msgID = " + message.getIntProperty("msgID"));
        }
        System.out.println("Message consumed "+message);
    }

    private void produceMessage(int messageID) throws JMSException {
        Message message = session.createTextMessage();
        message.setIntProperty("msgID",messageID);
        producer.send(message);
        System.out.println("Produced Message with msgID " + message.getIntProperty("msgID"));
    }

    private   void initialize() throws JMSException {
        connectionFactory = new ActiveMQConnectionFactory("vm://localhost");
        connection = connectionFactory.createConnection();
        connection.start();
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        destination= session.createQueue("TEST.FOO3");
        producer = session.createProducer(destination);
        producer.setDeliveryMode(DeliveryMode.PERSISTENT);
         consumer = session.createConsumer(destination);
        consumerWithSelector = session.createConsumer(destination,"msgID > 900");
    }
}

当我尝试使用 Message message = consumerWithSelector.receive(100); 它不消耗任何消息并打印以下输出

Produced Message with msgID 25000
Message consumed null

但是 Message message = consumer.receive(100); 正确地使用了消息，我们得到了以下输出。

Produced Message with msgID 25000
Consumed message with msgID = 25000
Message consumed ActiveMQTextMessage {commandId = 7, responseRequired = true, messageId = ID:didnsriina6-54782-1433918830039-3:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:didnsriina6-54782-1433918830039-3:1:1:1, destination = queue://TEST.FOO3, transactionId = null, expiration = 0, timestamp = 1433918830394, arrival = 0, brokerInTime = 1433918830394, brokerOutTime = 1433918844118, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = org.apache.activemq.util.ByteSequence@2330633a, dataStructure = null, redeliveryCounter = 0, size = 1040, properties = {msgID=25000}, readOnlyProperties = true, readOnlyBody = true, droppable = false, text = null}

请让我知道 messageSelector

中是否存在问题

Answer 1

我发现了问题。

这里我创建了两个消费者 consumer = session.createConsumer(destination); 和 consumerWithSelector = session.createConsumer(destination,"msgID > 900");

消费者 consumer 能够选择所有类型的消息，因为它在内部调用带有 null 选择器的方法作为 session.createConsumer(destination,(String)null);

因此该消息可供第一个 consumer 使用，而我的 consumerWithSelector 无法看到此消息。

解决这个问题

我评论了consumer = session.createConsumer(destination);

现在我可以看到过滤后的消息了。

JMS 消息选择器不工作

JMS Message Selector does not work

java

activemq

jms