Результаты поиска по запросу "rabbitmq"
Как заставить Spring RabbitMQ создать новую очередь?
В моем (ограниченном) опыте с rabbit-mq, если вы создаете новый прослушиватель для очереди, которая еще не существует, очередь создается автоматически. Я пытаюсь использовать проект Spring AMQP с rabbit-mq для настройки прослушивателя, и вместо ...
Получение количества сообщений в очереди RabbitMQ
Мы используемamqplib [http://barryp.org/software/py-amqplib/]публиковать / потреблять сообщения. Я хочу иметь возможность прочитать количество сообщений в очереди (в идеале как подтвержденные, так и неподтвержденные). Это позволит мне показать ...
Запуск задачи после завершения всех задач
Я пишу приложение, которое должно выполнять серию задач параллельно, а затем одну задачу с результатами всех выполненных задач: @celery.task def power(value, expo): return value ** expo @celery.task def amass(values): print str(values)Это очень ...
Сервис-ориентированная архитектура - AMQP или HTTP
Немного предыстории. Очень большое монолитное приложение Django. Все компоненты используют одну базу данных. Нам нужно разделить сервисы, чтобы мы могли самостоятельно обновлять некоторые части системы, не влияя на остальные. Мы используем ...
Сельдерей не освобождает память
Похоже, сельдерей не освобождает память после завершения задачи. Каждый раз, когда задача завершается, происходит утечка памяти на 5-10 метров. Так что с тысячами задач, скоро он будет использовать всю память. BROKER_URL = ...
Динамический выбор очереди RabbitMq в Exchange с помощью весенней интеграции
От производителя я должен отправить сообщение на биржу RabbitMQ. это сообщение будет содержать определенный атрибут, например, имя очереди, основываясь на этом атрибуте, я должен динамически определить очередь для отправки этого ...
Измените путь по умолчанию «home» в Erlang на Resolve RabbitMQ Ошибка запуска
Я новичок в rabbitmq и по ассоциации новичок в erlang. У меня проблема с тем, что я не могу запустить rabbitmq, так как местоположение «home» для .erlang.cookie было изменено. Я выполнил команду init:get_argument(home).который ...
Потребление не подтверждает сообщения от RabbitMq
У меня есть простой издатель и потребитель, который подписывается на очередь, используяbasic.consume. Мой потребитель подтверждает сообщения, когда работа выполняется без исключения. Всякий раз, когда я сталкиваюсь с исключением, я не ...
RabbitMQ обмен сообщениями никогда не получать сообщения
Я пытаюсь настроить свой первый обмен мертвыми буквами RabbitMQ, вот шаги, которые я использую через интерфейс веб-администратора:Создать новый ПРЯМОЙ обмен ...
Как задержать? - php-amqplib
Я хотел бы знать, как отложить с Amqpphplib.Я использовал этот замечательный учебник сценариев кофе:https://github.com/jamescarr/rabbitmq-scheduled-deliveryн...