Результаты поиска по запросу "rabbitmq"
или (в случае, если RabbitMQ управляется Supervisor):
могу удалить все отложенные задачи, не знаяtask_id для каждой задачи?
stackoverflow.com/questions/11926077/...
ся, чем дольше я работаю на своем сервере rabbitmq, тем больше у меня проблем с неподтвержденными сообщениями. Я хотел бы потребовать их. На самом деле, кажется, для этого есть команда amqp, но она применяется только к каналу, который использует ...
Спасибо за совет, хотя вы используете исключения совершенно неправильно ..
ей компании есть веб-сайт на основе Python и несколько рабочих узлов на основе Python, которые взаимодействуют через Django / Celery и RabbitMQ. У меня есть приложение на основе Java, которое должно отправлять задачи работникам из Celery. Я могу ...
отлично, спасибо
ли настроитьRabbitMQ сервер наAmazon EC2 instanceи мои машины в офисе подключаются к этомуRabbitMQ сервер и отправлять / получать сообщения на / с него? Я буду обвиненAmazon для пропускной способности / сообщений, которые поступают в / из ...
Этот класс Consumer предоставляет полученное событие, которое вы можете использовать, и поэтому НЕ блокирует. Остальная часть кода в основном остается прежней.
ичок в RabbitMQ. Я хочу иметь возможность обрабатывать чтение сообщений без блокировки, когда есть несколько очередей (для чтения из). Есть какие-то отзывы о том, как я могу это сделать? // Редактировать 1 public class Rabbit : IMessageBus { ...
Я бы построил ваш синглтон, такой как он имеет шаблон наблюдателя, и содержал бы там все содержимое RabbitMQ со ссылками на ваших абонентов. Затем вам также необходимо выполнить маршаллизацию вызовов для одного потока, который имеет дело с этим, или вы можете рисковать проблемами с объектами канала.
у простой класс, который мои приложения будут использовать для отправки и получения сообщений с использованием RabbitMQ. Я прочитал столько How-Tos, постов в блогах, официальных документов и тому подобного о RabbitMQ, сколько смог найти. В ...
Да, но потребителю не нужно ждать блокировки - он может перейти к следующей очереди. Предположительно, ваш протокол очередей также позволит потребителям отказаться от чтения сообщения из очереди, и тогда они смогут проверить блокировку.
тим, в вашей системе есть сущность, скажем «Персона», и вы хотите обрабатывать события, которые изменяют разные сущности Персоны. Важно что: События для одного и того же лица обрабатываются в порядке FIFOНесколько потоков людей обрабатываются ...
Если вы пойдете по пути построения Erlang вручную при минимальной установке ОС, вы также можете обнаружить, что вам нужно установить wxGTK & wxGTK-devel, чтобы все тесты были построены и работали правильно.
ался запустить rabbitmq-server-2.4.0 и запустить его на Centos 5.5 на экземпляре Amazon AWS. Мой экземпляр использует следующее ядро: 2.6.18-xenU-ec2-v1.2 Я пробовал установить erlang и rabbitmq-сервер, используя: 1) репозиторий yum 2) прямая ...
@cdeszaq: да, ты прав. Я написал это как ответ с немного большей информацией.
естве способа изучения RabbitMQ и python я работаю над проектом, который позволяет мне распределять коды h264 между несколькими компьютерами. Основы сделаны, у меня есть демон, который работает на Linux или Mac, который присоединяется к очереди, ...