parser

Написать ответ на текущее сообщение

 

 
   команды управления поиском

вроде понял

sergei v.2 18.10 22:58

$batch[^oAmqp.consume[
	$.queue[links]
	$.ack(true)
	$.timeout(3600)
	$.count(10)
]]

^batch.foreach[;h]{
	^processTask[$h]
}
Если в ваш пример добавить $.count(10), то оно будет ждать час пока не появится хоть одна задача и сразу возьмет от 1 до 10 штук за раз. Либо при consume уже в очереди будут ждать задачи и он выгребет оттуда сразу до 10 задач. И через ^while(1){... $batch[^oAmqp.consume[ ...] ...} повторяем прослушивание. Так?
Тогда мои вопросы снимаются -- этого функционала вполне достаточно для решения описанной мной выше задачи.