пользовательских компонент для чтения сообщений из очереди

Question

Я использую Mule 3.3.1

Я пытаюсь написать компонент, который считывает все имеющиеся сообщения из очереди, которые я намереваюсь быть опрошены с помощью планировщика Quartz.

Вот мой код.

@Override 
public Object onCall(MuleEventContext muleEventContext) throws Exception { 
    MuleMessage[] messages = null; 

    MuleMessage result = muleEventContext.getMessage(); 
    do { 
     if (result == null) { 
      break; 
     } 
     if (result instanceof MuleMessageCollection) { 
      MuleMessageCollection resultsCollection = (MuleMessageCollection) result; 
      System.out.println("Number of messages: " + resultsCollection.size()); 
      messages = resultsCollection.getMessagesAsArray(); 
     } else { 
      messages = new MuleMessage[1]; 
      messages[0] = result; 
     } 
     result = muleEventContext.getMessage(); 
    } while (result !=null); 
    return messages; 
} 

К сожалению, на первом сообщении он бесконечно петляет. Мысли?

Answer 1

OnCall метод(), предусмотренный в пост будет бесконечно цикла, потому что

muleEventContext.getMessage() 

всегда возвращает MuleMessage. И поэтому цикл будет проходить бесконечно.

Объект MuleEventContext здесь не является итератором или потоком, где указатель указывает на следующий элемент после считывания текущего элемента.

Чтобы прочитать все доступные сообщения из очереди. Вы можете подключить JMS для чтения путем опроса в очереди и прочитать все сообщения. Но помните, что каждое сообщение в очереди будет одной итерацией (одно сообщение) из вашей входящей JMS.

Если вы хотите собрать все сообщения очереди как набор объектов, а затем продолжить, то это совсем другая история. Это невозможно сделать с кодом компонента.

Если вы собираетесь собирать все свои сообщения в виде коллекции и затем начинать обработку, попробуйте использовать что-то вроде collection-aggregator мула на вашем входящем.

Надеюсь, это поможет.