0
ответов
Какую форму соединения использовать с пищухой
Я пытался выяснить, какую форму соединения я должен использовать при использовании pika, насколько я понимаю, у меня есть две альтернативы. Либо BlockingConnection, либо SelectConnection, однако...
вопрос задан: 16 August 2012 13:19
0
ответов
Rabbitmq прослушивает соединение UDP
Есть ли способ заставить RabbitMQ прослушивать соединения UDP и помещать эти пакеты в какую-то очередь по умолчанию, из которой затем может быть извлечен стандартный клиент? Что лучше: ActiveMQ или ZeroMQ...
вопрос задан: 15 August 2012 18:13
0
ответов
Может ли celery worker/server принимать задачи от производителя, не являющегося celery?
Я хочу использовать комет-сервер, написанный с использованием java nio, для отправки обновлений в реальном времени. При получении информации я хочу, чтобы она сканировала данные и отправляла задачи рабочим потокам через rabbitmq. В идеале я бы...
вопрос задан: 15 August 2012 06:02
0
ответов
Где реализации AMQP 1.0? Есть ли смысл ждать?
Я провожу исследование, чтобы выяснить, какое решение для обмена сообщениями выбрать для наших будущих продуктов, и я не могу понять это. Есть куча реализаций AMQP 0.9.1 (RabbitMQ, Apache...
вопрос задан: 13 August 2012 19:26
0
ответов
Ищем простой постоянный буфер сообщений в Java
Я ищу простой постоянный буфер в качестве временного хранилища для сообщений JSON в приложении Java. Использование памяти должно быть относительно постоянным и не зависеть от количества сообщений в...
вопрос задан: 13 August 2012 13:53
0
ответов
Сообщения RabbitMQ :остаются «неподтвержденными»
Мое приложение Java отправляет сообщения в обмен RabbitMQ, а затем обменивает перенаправляет сообщения в связанную очередь. Я использую java-плагин Springframework AMQP с RabbitMQ. Сообщение о проблеме :поступает в очередь,...
вопрос задан: 12 August 2012 21:56
0
ответов
Настройки RabbitMQ исчезают при перезапуске. Почему?
Это на ЕС2. У меня есть сценарий инициализации, который выполняет некоторые базовые настройки, такие как установка rabbitmq, создание виртуального хоста, пользователя, настройка разрешений и т. д. Так что в основном это :sudo yum --enablerepo=epel...
вопрос задан: 10 August 2012 18:16
0
ответов
RabbitMQ с WCF и постоянной очередью
Я пытаюсь написать службу wcf, которая работает через привязку rabbitMQ. Мне удалось успешно создать сервер и клиента, и клиент отправлял сообщения на сервер через очередь. Я ...
вопрос задан: 19 July 2012 18:49
0
ответов
Ошибки кадрирования в Celery 3.0.1
Недавно я обновился до Celery 3.0.1 с 2.3.0, и все задачи выполняются нормально. К сожалению. Я довольно часто получаю исключение «Ошибка кадра». Я также запускаю супервизора для перезапуска потоков...
вопрос задан: 13 July 2012 23:34
0
ответов
URL-кодирование косой черты (/ )в.NET
Как я могу заставить либо Uri, либо HttpWebRequest разрешать uri, содержащий как /, так и %2f, как показано ниже? http ://localhost :55672/api/exchanges/%2f/MyExchange Я попробовал это... Запрос WebRequest =...
вопрос задан: 13 July 2012 20:35
0
ответов
Размер очереди в Java-клиенте Spring AMQP
Я использую версию Spring amqp 1.1 в качестве своего java-клиента. У меня есть очередь, в которой около 2000 сообщений. Я хочу иметь службу, которая проверяет размер этой очереди и, если она пуста, отправляет...
вопрос задан: 12 July 2012 06:54
0
ответов
Как связать Web и Worker dynos с Node.js на Heroku?
Web Dynos может обрабатывать HTTP-запросы, и в то время как Web Dynos обрабатывает их, Worker Dynos может обрабатывать от него задания. Но я не знаю, как заставить Web Dynos и Worker Dynos общаться друг с другом. Для...
вопрос задан: 11 July 2012 09:39
0
ответов
Как реализовать модель одиночной -потребительской -множественной -очереди для rabbitMQ
Я обнаружил, что этот образ очень похож на мою бизнес-модель. Мне нужно разделить сообщение на некоторую очередь. для какой-то тяжелой работы. Я могу добавить больше рабочего потока для них. Но для некоторых нет особо тяжелой работы. Я...
вопрос задан: 6 July 2012 07:13
0
ответов
Случайная ошибка тайм-аута с Pika и gevent
Я пытался использовать RabbitMQ из моей программы gevent, используя библиотеку Pika (обезьяна, исправленная gevent), gevent любит случайно выдавать ошибку тайм-аута. Что мне делать? Есть ли...
вопрос задан: 30 June 2012 18:02
0
ответов
Лимит подключения Rabbit MQ?
Я работаю над структурой обмена сообщениями, которая выводит список и публикует на Rabbitmqserver в java следующий код: ConnectionFactory factory = new ConnectionFactory(); factory.setHost(...
вопрос задан: 28 June 2012 18:40
0
ответов
RabbitMQ Тематические обмены: 1 Exchange vs Many Exchanges
У меня есть сценарий, в котором я ряд процессов, которые мне нужно выполнить, каждый шаг выполняется и масштабируется в независимых приложениях. Я использую тематические обмены для всех обменов. Текущая топология ...
вопрос задан: 28 June 2012 16:35
0
ответов
Синхронизация одного экземпляра очереди с несколькими экземплярами Redis
Сценарий :У нас есть несколько узлов, распределенных географически, на которых мы хотим иметь очереди, собирающие сообщения для этого местоположения. И затем мы хотим отправить эти собранные данные из каждой очереди в...
вопрос задан: 28 June 2012 11:08
0
ответов
RabbitMQ — выборочное извлечение сообщений из очереди
. Я новичок в RabbitMQ, и мне было интересно найти хороший подход к этой проблеме, над которой я размышляю. Я хочу создать службу, которая подписывается на очередь и извлекает только те сообщения, которые соответствуют определенным критериям;...
вопрос задан: 21 June 2012 15:58
0
ответов
Веб-консоль управления RabbitMQ не показывает очереди или обмены.
У меня настроен RabbitMQ 2.8.2 с запущенным веб-интерфейсом управления. Очереди и обмены не показывают данных. rabbitmqctl list_queues работает и показывает мои очереди. Я сделал rabbitmqctl stop_app, ...
вопрос задан: 7 June 2012 20:42
0
ответов
Как заставить несколько рабочих celery выполнять одни и те же задачи?
У меня есть одна задача, которая проверяет скорость URL-адреса, но я хочу, чтобы выполняться несколькими работниками celery на разных серверах. хотите, чтобы один и тот же URL-адрес проверялся несколькими работниками. Как я могу это сделать?
вопрос задан: 17 May 2012 12:27
0
ответов
Amazon-SQS + Django-Celery создает тысячи очередей (очередь для каждого сообщения)
Я ищу место, где можно начать устранение этой проблемы. вот изменения, сделанные в настройках settings.py #Rabbit MQ
#================================================ ====================...
вопрос задан: 16 May 2012 19:04
0
ответов
RabbitMQ/AMQP: одна очередь, несколько потребителей для одного и того же сообщения?
Я только начинаю использовать RabbitMQ и AMQP в целом. У меня есть очередь сообщений
У меня есть несколько потребителей, которым я хотел бы делать разные вещи с одним и тем же сообщением. Большая часть RabbitMQ...
вопрос задан: 16 May 2012 14:56
0
ответов
Ошибка соединения потребителя с django и celery+rabbitmq?
Я пытаюсь настроить celeryd с помощью django и rabbit-mq. До сих пор я сделал следующее: Установил celery из pip
Установил rabbitmq через debs, доступные в их репозитории.
Добавил пользователя и...
вопрос задан: 16 May 2012 01:48
0
ответов
rabbitmq отказывается запускаться
Я установил rabbitmq на ubuntu и пытаюсь запустить его с помощью запуска сервера rabbitmq -, однако я получаю эту ошибку :Activating RabbitMQ плагины... 0 плагинов активировано :узел с именем "кролик"...
вопрос задан: 15 May 2012 21:38
0
ответов
«Hello World» не работает для rabbitmq
Я новичок на rabbitmq, но по какой-то (неизвестной) причине "hello
программа "мир" у меня не работает.
Файлы send.py и Receive.py просто копируются и вставляются из
страница руководства: http://www....
вопрос задан: 14 May 2012 17:18
0
ответов
ESB для Python? [закрыто]
На работе мы обсуждаем выбор готовой полнофункциональной ESB (Enterprise Service Bus -- http://en.wikipedia.org/wiki/Enterprise_service_bus ) вместо развертывания нашей собственной вокруг AMQP. система типа...
вопрос задан: 10 May 2012 19:53
0
ответов
Как можно реализовать распределенную очередь -, подобную -, поверх RBDMS или хранилища данных NOSQL или другой системы обмена сообщениями (, например, rabbitmq )?
Из не было бы -это -было бы -круто -если категория вопросов... Под "очередью -как -вещь" я имею в виду поддержку следующих операций :добавить (запись :запись)-добавить запись в конец очереди взять ():запись -удалить...
вопрос задан: 10 May 2012 08:00
0
ответов
Как загрузить -дистрибутив в кластер RabbitMQ?
Привет, я создаю три сервера RabbitMQ, работающих в кластере на EC2. Я хочу масштабировать кластер RabbitMQ на основе использования ЦП, но когда я публикую сообщение, только один сервер использует ЦП, а другой RabbitMQ -...
вопрос задан: 5 May 2012 12:24
0
ответов
Соединение RabbitMQ в состоянии блокировки?
Я подключаюсь к серверу RabbitMQ, когда мое соединение отображается в состоянии блокировки, и я не могу опубликовать новое сообщение. У меня есть 6 ГБ свободной оперативной памяти, а на диске также около 8 ГБ. Как настроить диск ...
вопрос задан: 3 May 2012 07:34
0
ответов
Есть ли разница в производительности между объединением соединений или каналов в rabbitmq?
Я новичок в Rabbitmq (и программировании ), так что извините заранее, если это очевидно. Я создаю пул для совместного использования между потоками, работающими в очереди, но я не уверен, следует ли мне использовать...
вопрос задан: 2 May 2012 04:31