consume без $.callback[]

moko 08.01 19:17

consume - возможно имеет смысл добавить вариант без коллбека, чтобы просто возвращал сообщение?

да. хорошая мысль. чтобы не делать get_message, который полезен и там надо бы запланировать брать сразу N-сообщений из очереди (одно по умолчанию)

Сделано, если не задан $.callback[] возвращается массив сообщений. Число сообщений задается через $.count(N), одно по умолчанию.

Надо понимать, что если сообщений нет, amqp ждет их до timeout (по умолчанию 30 минут). Будет исключение (в отличии от варианта с callback, который завершается без ошибки).

Пока не очень понятно, как все это будет использоваться. Хорошо бы было какое-нибудь реальное приложение, с которым можно "поиграться", а не просто мои тесты. Сейчас непонятно, как вести себя в пограничных ситуациях. Например в amqp после любой ошибки канал считается мёртвым. То есть и дальнейшие попытки работать с ним будут приводить к исключениям. Надо ли его переоткрывать? Но автоматически это делать странно, там же так понимаю надо переподписывать consumers...

---