Если так, то нету гарантии что сообщения будут обработаны в

том порядке в котором они находятся в очереди, как отследить что последнее сообщение из 10 к примеру было обработано?
При том что в очереди могут быть сообщения которые принадлежат к примеру другому пользователю

9 ответов

11 просмотров

Очередность выполнения есть, просто ваше сообщение может забрать другой консьюмер

Vitalii- Автор вопроса
kool jan
Очередность выполнения есть, просто ваше сообщение...

В таком случае есть вероятность что последнее сообщение будет обработано предпоследним к примеру

Vitalii
В таком случае есть вероятность что последнее сооб...

ну. почему? сообщения закидываются по FIFO

Vitalii
В таком случае есть вероятность что последнее сооб...

если вам нужна строгая последовательность - то на очередь делаем одного консьюмера с префетч каунтом 1

Vitalii- Автор вопроса
kool jan
ну. почему? сообщения закидываются по FIFO

К примеру 10/10 сообщение это 30 слов а 9/10 это 2 слова, 2 консьюмера забирают эти сообщения почти одновременно, но на обработку длинного уйдет больше времени

Vitalii
К примеру 10/10 сообщение это 30 слов а 9/10 это 2...

а какая разница сколько будет длится обработка

Aleksey Barabanov
если вам нужна строгая последовательность - то на ...

Мне кажется не стоит даже рассчитывать. Так можно сделать, а потом кто-то зайдёт в админку чтобы посмотреть какие в очереди висят сообщения и всё пойдёт наперекосяк

Похожие вопросы

Обсуждают сегодня

Всем привет, есть ли возможность как то приоритизировать сообщение в очереди, то есть по сути класть в начало , у нас есть что то что 5, очередь ->1,3,2-> по обычному ->5,1,3...
Pepel📰
2
Приветству. Такой вопрос, как правильно поставить werf в fish shell, кто-нибудь делал такое?
Michael Makarochkin
2
Добрый день. Есть вопрос по новому механизму Nelm - возможно ли отключить при генерации итогового NOTES.txt вложенные сабчарты (точнее NOTES.txt из вложенных сабчартов)? Прежн...
Сергей Голод
2
Еще одну панику поймал: $ werf helm repo add --username gitlab --password ${CI_JOB_TOKEN} helm-werf ${HELM_REPO_V2_URL} "helm-werf" has been added to your repositories $wer...
citius
1
Вот такая неприятность на stable и ea версиях: werf helm --namespace s4c upgrade --install --atomic --timeout 5m --set s4c.version=839185f3 --set s4c.deployEnv=staging -f d...
citius
6
Честно говоря замучался с пробросом токена из Github Secrets. Из документации все равно ничего непонятно, перебираю всевозможные варианты оттуда, пока ничего не работает. Ест...
1
Блин а мне как поумнеть ?
Toxin
191
pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...
Sergey
9
Чем принципиально отличается ack от reject (requeue=false)? Оба же удаляют сообщения из очереди?
Юрий
54
Вроде всё верно, imagePullSecrets находится в секции spec. Возможно в Secret указано что-то не в том формате (а именно ключ ".dockerconfigjson"). Поищу информацию. А этот Secr...
3
Карта сайта