| Новости | FAQ | Авторы | Документация | В действии | Библиотека |
| Инструменты | Полезные ссылки | Хостинги | Скачать | Примеры | Форум |
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[ ...] ...} повторяем прослушивание. Так?