无法从 activemq 队列中删除特定消息答案

【问题标题】：can not delete specific message from activemq queue无法从 activemq 队列中删除特定消息
【发布时间】：2017-01-04 22:12:43
【问题描述】：

我正在尝试使用 java 获取我在 activeMQ 队列中的所有消息的列表，并根据它们的 ID 删除其中一条消息。我的代码如下所示：

Connection connection = connectionFactory.createConnection("username","password");
            connection.start();
            Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            Destination topicDestination = session.createQueue(queue_name);
            QueueBrowser browser = session.createBrowser((Queue) topicDestination);
            Enumeration<?> messages = browser.getEnumeration();
            int count=0;
            while( messages.hasMoreElements()){
                count++;
                TextMessage messageInTheQueue = (TextMessage)messages.nextElement();
                System.out.println("Message "+count+" in the queue:" );
                System.out.println(messageInTheQueue.getJMSMessageID());
                System.out.println(messageInTheQueue.getText());
                System.out.println("===============================================");
                System.out.println(" ");

当我运行它时，我得到以下输出：

Message 1 in the queue:
ID:message1-server-42764-1483561148119-0:0:1:1:1
Today is warm
===============================================

Message 2 in the queue:
ID:message1-server-42764-1483561148119-0:0:1:1:2
Today is dry
===============================================

我使用我得到的 ID，例如第二个 ID message1-server-42764-1483561148119-0:0:1:1:2 来使用或删除消息，如下所示：

Connection connection = connectionFactory.createConnection("username","password");
            Session session = connection.createSession(true,Session.AUTO_ACKNOWLEDGE);
            Destination topicDestination = session.createQueue(queue_name);
            MessageConsumer consumer = session.createConsumer(topicDestination, "JMSMessageID="+message_id); 
            connection.start(); 
            consumer.receive();
            consumer.close(); 
            session.commit(); 
            session.close(); 
            connection.stop();

但我不断收到 jms 异常：

 javax.jms.InvalidSelectorException: JMSMessageID=message1-server-42764-1483561148119-0:0:1:1:2
        at org.apache.activemq.selector.SelectorParser.parse(SelectorParser.java:47)
        at org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:186)
        at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:840)
        at activeMQ.DeleteSingleMessage.run(DeleteSingleMessage.java:30)
        at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.activemq.selector.TokenMgrError: Lexical error at line 1, column 51.  Encountered: ":" (58), after : ""
        at org.apache.activemq.selector.SelectorParserTokenManager.getNextToken(SelectorParserTokenManager.java:1057)
        at org.apache.activemq.selector.SelectorParser.jj_scan_token(SelectorParser.java:1133)
        at org.apache.activemq.selector.SelectorParser.jj_3R_18(SelectorParser.java:849)
        at org.apache.activemq.selector.SelectorParser.jj_3R_11(SelectorParser.java:857)
        at org.apache.activemq.selector.SelectorParser.jj_3R_9(SelectorParser.java:883)
        at org.apache.activemq.selector.SelectorParser.jj_3_5(SelectorParser.java:916)
        at org.apache.activemq.selector.SelectorParser.jj_2_5(SelectorParser.java:563)
        at org.apache.activemq.selector.SelectorParser.addExpression(SelectorParser.java:323)
        at org.apache.activemq.selector.SelectorParser.comparisonExpression(SelectorParser.java:172)
        at org.apache.activemq.selector.SelectorParser.equalityExpression(SelectorParser.java:132)
        at org.apache.activemq.selector.SelectorParser.andExpression(SelectorParser.java:96)
        at org.apache.activemq.selector.SelectorParser.orExpression(SelectorParser.java:75)
        at org.apache.activemq.selector.SelectorParser.JmsSelector(SelectorParser.java:67)
        at org.apache.activemq.selector.SelectorParser.parse(SelectorParser.java:44)
        ... 4 more

我尝试关注this 的帖子，但我不确定我错过了什么？

【问题讨论】：

我不完全确定，但我认为您必须将Message ID 设置为等于Correlation ID 或类似的东西才能实现此目的。我记得在使用 IBM Websphere 时遇到过类似的问题。但正如我所说，我对此并不完全确定。
感谢您的评论！我尝试获取相关 ID，但它返回 null
异常是否为您提供了有关问题所在的更多详细信息？
@DaveH 请查看我更新的问题以及详细的异常消息。我还发现了this post，我不确定它是否相关
尝试将消息选择器用单引号括起来。 JMSMessageID='"+message_id+"'");

标签： java jms activemq

【解决方案1】：

 javax.jms.InvalidSelectorException: JMSMessageID=message1-server-42764-1483561148119-0:0:1:1:2

你忘记了ID: 的JMSMessageID

添加它并将选择器值用单引号括起来

  String message_id = "'ID:message1-server-42764-1483561148119-0:0:1:1:2'";
  MessageConsumer consumer = session.createConsumer(topicDestination, "JMSMessageID=" + message_id);

【讨论】：