Как синхронизировать onMessage() MessageListener

Question

У меня есть веб-приложение spring3. Я использую 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 как потребитель сообщений, который обрабатывает сообщение синхронно. Тем не менее, я хочу получать сообщения списка из очереди, чтобы пользователь мог удалить его, если захочет. Превышение кода возвращает нулевой список, если у меня есть потребитель очереди.