Перечень потребителей activemq - PullRequest
0 голосов
/ 08 октября 2009

Можно ли использовать ActiveMQ-потребитель (в .NET), как это?

foreach (переменная msg в потребителе) {

// обработать сообщение

}

так, что цикл перечисления останавливается без использования ЦП, пока сообщение не станет доступным? По сути, это будет бесконечный цикл, если что-то пойдет не так.

1 Ответ

0 голосов
/ 07 марта 2011

Вы можете выполнить синхронное потребление для достижения чего-то подобного с помощью цикла while:

IMessage message = null;
while((message = consumer.Receive()) != null)
{
    //... process the message.
}

-Tim www.fusesource.com

...