Всем привет. Начал изучение RabbitMQ и столкнулся с проблемой того,

что очереди для ответа не удаляются, так как у них по какой-то причине остается консюмер. Как это исправить?

11 ответов

68 просмотров

убить консюмера

Владислав Килин
убить консюмера

Скорее разработчика такого консьюмера)

Владислав Килин
убить консюмера

Консьюмера может уже не быть в живых - при выключеном хербите

Aleksey Barabanov
Скорее разработчика такого консьюмера)

я щас ваще не удивлюсь если это плохо сваренный селери или масстранзит просто

Dmitriy-Basenko Автор вопроса
Владислав Килин
убить консюмера

Пробую на Go. Как там можно убить консюмера, если он возвращает только канал с сообщениями и ошибку? Создание нового канала на каждого консюмера решило проблему. Но мне почему-то кажется что это плохо влияет на производительность. Или я ошибаюсь?

Dmitriy-Basenko Автор вопроса
Dmitriy-Basenko Автор вопроса

Спасибо. Отличный развернутый ответ

Dmitriy-Basenko Автор вопроса

Это касается только консьюмеров или паблишеров тоже?

Dmitriy Basenko
Это касается только консьюмеров или паблишеров тож...

Смотря, в какой среде паблишеры живут. Если вы их используете в стандартном хттп сервере, то там горутина на каждый запрос создается. На каналы не запасетесь. Можно через один канал.

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

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

Всем привет. Понимаю, что, наверное, сто раз поднимали эту тему, но по ключевым словам не смог найти. Как передать в values.yaml зависимого хелм-чарта теги образов, собираемых...
Vitalik Petrov
4
Всем привет. Werf v2.10.5 При удалении релиза вместе с неймспейсом (werf dismiss --namespace namespace_name) Сыпятся ошибки ┌ Waiting for resources elimination: namespaces/rel...
Vitalik Petrov
1
@aigrychev, @ilya_lesikov добрый день! а поддерживает ли werf helm xxxx или werf bundle xxxx работу с сабчартами через http-прокси? (сработает ли использование HTTP_PROXY/HTTP...
Сергей Голод
4
Добрый день! Удалил все файлы с переменными из проекта, получил Error: release deploy: process resources: error validating adoptable resources: adoption validation failed: re...
Evgheni Mad
2
Привет! Вопрос про werf helm Приложение деплоится через werf helm upgrade --atomic Иногда(все условия для воспроизведения до конца непонятны, но есть версия, что это происходи...
𝓐𝓵͢͢͢𝓮𝔁 C
2
Всем привет. Сегодня добавили в приложение дополнительный образ nginx, в который докидывается системная статика прям в образ. При деплое бандлами деплоилось 200+ джоб(клиентов...
Владимир Муковоз
6
Добрый день, после перехода с версии 1.2 на 2.10 werf cleanup начал удалять использующиеся теги, и до и после обновления использовались дефолтные политики keepPolicies Подскаж...
Дмитрий
29
Блин а мне как поумнеть ?
Toxin
191
Друзья, добрый день. Прошу подсказать с базовым вопросом по использованию CI переменных gitlab в werf.yaml. Хочу в beforeInstall использовать env переменную с токеном. Мне нуж...
Anton Zol
10
Вопросик не совсем werf. Но вдруг мы подскажите воркэраунд или ещё что-нибудь. Могу ли я как-нибудь в моменте деплоя внутри heml рендера получить хэшсумму файла шаблона (./tem...
Alex Подрябинкин
11
Карта сайта