MessageListener的onMessage()如何同步

Question

我有一个 spring3 Web 应用程序。我使用 org.springframework.jms.listener.DefaultMessageListenerContainer 来配置我的消息侦听器。我注册了一个 MDPOJO。我想要的是，当 onMessage() 正在为特定请求执行时，其他人应该等到第一个请求完成。换句话说，onMessage() 方法调用进一步的工作流程，完成它需要时间。其他消息在确认先前的请求完成之前，onMessage 不应选择队列中的队列。

是否可以同步处理onMessage()。我需要做以下事情：

1. 用户将发布 n 条消息到队列中
2. 我应该有一个界面，用户可以在其中从队列中删除消息。
3. 当一条消息正在处理中时，不应接收任何其他消息。
4. 用户应该能够更改消息处理的优先级

Answer 1

我可以使用以下代码以编程方式列出队列中的消息：

public void listAllJMS_Messages() 
    {
        try {
            ObjectName objectName=new ObjectName("jboss.messaging.destination:name=DLQ,service=Queue");
            List ls = (List) server.invoke(objectName, "listAllMessages" , null, null);
            List<javax.jms.Message> messages=(List<javax.jms.Message>)server.invoke(objectName, "listAllMessages" , null, null);
            int count=0;
            for(javax.jms.Message msg : messages) {
                System.out.println((++count)+"t"+msg.getJMSMessageID());
               if(msg.getJMSType() != null && msg.getJMSType().equalsIgnoreCase("Text")) {
                TextMessage text = (TextMessage)msg; 
                System.out.println(text.getText());
               }
            }
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } 

        // System.out.println((++count)+"t"+msg.getText());
    }

但是上面的代码列出了来自那些队列的消息，这些消息到目前为止还没有任何消费者。我的情况是，我有一个 MDPOJO 作为同步处理消息的消息消费者。我仍然想要从队列中列出消息，以便用户可以根据需要删除它。上面的代码返回空列表，以防我有队列的消费者。