parser

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

 

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

Ответ

moko 15.10 17:58

1. Каким образом получить пачку задач в callback?
Никаким. В режиме callback сообщения ожидаются, получаются и передается в callback по одному.

Хотите пачку - используйте второй режим consume. Но надо понимать, что он тоже не гарантирует пачку задач, count означает "не больше". Если в очереди будет только одно сообщение - он одно и отдаст... Или даже ни одного, если timeout случится раньше. Из operators.txt:
^amqp.consume[ $.queue[имя] $.callback[$метод] ... ]
вызывает @метод[сообщение] для каждого сообщения до ^amqp.stop_consume[], count сообщений или timeout секунд без сообщений
^amqp.consume[ $.queue[имя] $.ack(true) $.count(1) $.timeout(0) $.exclusive(false) $.consumer_tag[] ]
массив сообщений, готовых за timeout секунд (ждётся только первое)
2. Сейчас ack принимает только один числовой параметр.
Там и строку можно переделать, но да, delivery tag это число. Обработали сообщение -> подтвердили. Если здесь есть вопрос, то я его не понял.