Ответ

moko 15.10 18:39

В режиме callback count задает число сообщений, через которое ^amqp.consume завершится. По умолчанию там -1 (никогда), но при необходимости можно ограничить. Например чтобы запустить сборку мусора, делать ротацию логов раз в 1000 сообщений или еще какие-нибудь действия, которые удобно делать именно раз в N сообщений.

AMQP - для обсуждения, sergei v.2 11.09.2025 20:18
- Может в consume опционально под капотом сделать создание очереди, кторую собираемся слушать если её там ещё нет?, sergei v.2 05.12.2025 12:48
- Может кстати упростить API?, moko [M] 26.11.2025 05:34
  - Я вот думаю что может сделать два параметра - строка name ; hash параметров, sergei v.2 27.11.2025 00:54
    - consume без $.callback[], moko [M] 08.01 19:17
      - Пример более сложного приложения с очередями и биржами ..., sergei v.2 09.09 12:27
      - Ответ, virusav 09.09 09:18
      - Ответ, sergei v.2 09.09 00:24
        Ещё раз про таймаут, sergei v.2 09.09 12:42
        Ответ, moko [M] 15.09 02:08
        callback + count, virusav 15.10 11:17
        Ответ, moko [M] 15.10 17:58
        А почему нельзя сделать такую фичу, чтобы если задан count, оно брало есил есть что взять не одну задачу, а пробовало набрать себе в буфер N задач и вызывало колбек функцию 1 раз и передавало туда весь этот буфер массивом на , sergei v.2 16.10 13:53
        Непонятно зачем, moko [M] 16.10 14:31
        мы сейчас делаем такую задачу ..., sergei v.2 16.10 18:36
        Показал оба варианта в демо-приложении, moko [M] 16.10 21:00
        вроде понял, sergei v.2 18.10 22:58
        Да, именно так (-), moko [M] 18.10 23:01
        $.timeout, moko [M] 16.10 18:55
        а через опрос это надо просто постоянно долбить ребит в цикле, даже когда там нет задач, а не слушать появление новых задач (-), sergei v.2 16.10 18:37
        нет, moko [M] 16.10 18:39 / 16.10 18:55
        Что именно делает count в callback? (-), virusav 15.10 18:32
        Ответ, moko [M] 15.10 18:39
        Может count в limit переименовать? (-), Sumo [M] 16.10 09:13
        Скорее развести. :), moko [M] 16.10 13:07
        Хорошо бы чтобы в коллбек функцию приходил парамтером массив таксов из ребита, чтобы просто крутить цикл по нему в этйо функции по пачке, а не собирать через глобальную перемнную как-то (-), sergei v.2 15.10 11:36
        Это всё уже в ночных сборках уже есть? И можно этот предрелиз из гита тянуть, компилить и тестировать с пристрастием? (-), sergei v.2 15.09 14:20
        Вот теперь наверное можно :), moko [M] 16.09 01:13
        Отложенные задачи, virusav 28.09 18:01
        Ответ от GPT, не проверял. :), moko [M] 28.09 20:13
    - упрощение API, moko [M] 08.01 19:03
      - А куда делся ключ nowait для declare?, virusav 08.09 19:13 / 08.09 19:30
        Ответ, moko [M] 09.09 03:04
    - Ответ, virusav 27.11.2025 21:08 / 27.11.2025 21:09
      - два параметра - строка + hash опций, moko [M] 08.01 19:26
      - Ответ, n3o 27.11.2025 22:33
    - Когда-то писал простой класс для работы с api rabbit mq - там пример pull(N) через api, sergei v.2 27.11.2025 00:59
- Да, так гораздо лучше, moko [M] 12.09.2025 04:08
  - Ответ, sergei v.2 15.09.2025 14:01
    - этого достаточно? (-), sergei v.2 24.09.2025 13:45
      - Для первой итерации - вполне (-), moko [M] 24.09.2025 17:21
        А есть какой-то прогноз, когда это можно будет попробовать в релизе или в ночных сборках? :) (-), sergei v.2 24.09.2025 20:56
        Надеюсь примерно через месяц будет в ночных сборках (-), moko [M] 25.09.2025 05:01
        Получается? (-), sergei v.2 06.11.2025 19:18
        Что-то даже работает, moko [M] 08.11.2025 03:39
        можно под redhat, fedora и еже с ними x86_64 (-), sergei v.2 08.11.2025 11:50
        готово, moko [M] 08.11.2025 15:19
        а почему это секретная ссылка:? :), sergei v.2 03.12.2025 12:56
        https://www.parser.ru/download/, G_Z [M] 03.12.2025 16:08
        там нет ссылки ..., sergei v.2 03.12.2025 16:21
        А, речь именно про AMQP, G_Z [M] 03.12.2025 16:25
        Как перебрать все имеющиеся задачи?, virusav 25.11.2025 14:47
        От вас с Сергеем ждут не только вопросы, а предложения…, Sumo [M] 25.11.2025 15:35 / 25.11.2025 15:37
        Ответ, virusav 26.11.2025 10:57 / 26.11.2025 11:29
        Планируются ли очистка очереди, постановка задач пачкой и подсчет количества задач? (-), virusav 24.11.2025 16:20
        Вы же API предлагаете, moko [M] 26.11.2025 05:19
        Да, пойдет. (-), virusav 26.11.2025 15:02
        Проблема в ack, virusav 21.11.2025 16:49
        все правильно, moko [M] 22.11.2025 18:38
        Ответ, virusav 21.11.2025 14:29
        Не надо, moko [M] 21.11.2025 18:00
        Странно, но с N-го раза заработало, virusav 21.11.2025 15:58
        Ответ, moko [M] 21.11.2025 18:17
        Частично, moko [M] 07.11.2025 01:35

Новости	FAQ	Авторы	Документация	В действии	Библиотека
Инструменты	Полезные ссылки	Хостинги	Скачать	Примеры	Форум