1
ответ

Java обмен сообщениями JMS

У меня есть рабочий пример передающего сообщения к серверу и серверу, получающему его через обмен сообщениями qpid. Здесь просто привет мир для отправки к серверу: http://pastebin.com/M7mSECJn И вот является сервером который...
вопрос задан: 1 June 2010 08:56
1
ответ

Каков “режим доставки” в AMQP?

Я понимаю, что 2 опции доступны: "Нестойкий" "Персистентный", Но что это на самом деле означает? "Нестойкий" как в: матрица AMQP попытается передать сообщение, если будет нет...
вопрос задан: 26 February 2010 08:46
1
ответ

Получите сообщения от очереди (очередей) RabbitMQ

Я надеюсь реализовывать RabbitMQ в свое приложение PHP и использую php-amqp расширение. Мой единственный вопрос - это, как я легко запрашиваю для возврата содержания очереди в PHP? php-amqp...
вопрос задан: 7 February 2010 00:50
1
ответ

Как я могу настроить Сельдерей, чтобы вызвать таможенную функцию инициализации прежде, чем управлять моими задачами?

У меня есть проект Джанго, и я пытаюсь использовать Сельдерей, чтобы представить задачи для фоновой обработки (http://ask.github.com/celery/introduction.html). Сельдерей объединяется хорошо с Джанго, и я был в состоянии...
вопрос задан: 25 January 2010 04:07
1
ответ

В FIFO система Qeueing, что лучший способ для реализации приоритетного обмена сообщениями

Для ориентированного на сообщение промежуточного программного обеспечения, которое последовательно не поддерживает сообщения с приоритетом (такие как AMQP), что лучший способ состоит в том, чтобы реализовать приоритетное потребление, когда у очередей есть
вопрос задан: 16 July 2009 17:48
1
ответ

Как Вы закодировали бы Карту <Строка, Объект> использование Буферов Протокола?

Я пытаюсь использовать Буферы Протокола для сериализации сообщения. Мой формат сообщения должен содержать Карту <Строка, Объект> записи..., но как я пишу .proto определение? Насколько я знаю...
вопрос задан: 9 July 2009 09:51
0
ответов

Используя RabbitMQ, есть ли способ просмотреть содержимое очереди без операции удаления из очереди?

В качестве способа изучения RabbitMQ и python я работаю над проектом, который позволяет мне распределять кодировку h264 между несколькими компьютерами. Основы готовы, у меня есть демон, работающий на Linux или Mac ...
вопрос задан: 14 August 2019 21:57
0
ответов

Как я могу увидеть содержимое сообщений в моей консоли управления Qpid Broker?

Я использую очереди в приложении Java для создания и потребления сообщений, которые проходят через них. Я хотел бы проверить содержимое полезной нагрузки, которую я отправляю, с помощью QPID Broker (документация: ...
вопрос задан: 19 March 2019 20:13
0
ответов

Каковы различия между AMQP 0-9-1 и AMQP 0-10?

Различия между AMQP 0-10 и AMQP 1.0 подробно описаны в Интернете. Я не могу найти какие-либо подробности или журнал изменений о различиях между AMQP 0-9-1 и 0-10 Каковы основные отличия ...
вопрос задан: 6 March 2019 13:35
0
ответов

Angular: Qs.unescape не является функцией, использующей amqp-ts

Я хотел бы использовать amqp-ts Libary в Angular. Но во время его использования я получил эту ошибку: необработанное отклонение: ошибка типа: QS.unescape не является функцией openFrames @ http: // localhost: 4200 / vendor.js: 55720: ...
вопрос задан: 17 January 2019 08:25
0
ответов

AMQP - асинхронный RPC - фьючерс на возврат значения приводит к «неожиданному возвращаемому значению»

Я хотел бы выполнить асинхронную связь в стиле RPC. Я использую AMQP RabbitMQ для этой цели: я отправляю свое сообщение с помощью AsyncRabbitTemplate, определяя тип возвращаемого значения в виде списка myObj ...
вопрос задан: 15 January 2019 18:17
0
ответов

Инструменты документации для API RPC

Есть множество хороших инструментов для исходного кода и документации API (doxygen, Headerdoc, Sphinx, и это лишь некоторые из них). Однако ни один из них не кажется особенно хорошим в создании ...
вопрос задан: 23 December 2018 10:32
0
ответов

установка amqp на mac с помощью brew

Я хотел установить amqp с pecl для моей Mac Sierra. Я установил php с brew, при установке pecl amqp я получаю сообщение об ошибке: проверка amqp с помощью pkg-config ... configure: error: librabbitmq not ...
вопрос задан: 13 August 2018 08:51
0
ответов

RabbitMQ - Чат - Новичок

Я новичок в RabbitMQ, и я хочу сделать простую систему чата, но я не знаю, какую библиотеку следует использовать для установления соединения с бэкэнд (на самом деле, у меня нет кодировки, но я буду делать ...
вопрос задан: 13 July 2018 21:52
0
ответов

Особые преимущества NServiceBus перед простым RabbitMQ

Есть ли преимущества использования NServiceBus по сравнению с простым использованием драйвера .net для RabbitMQ (при условии, что мы можем заменить MSMQ на AMQP). Предоставляет ли NSB дополнительную функциональность или абстракции ...
вопрос задан: 25 July 2017 07:27
0
ответов

Producer work consistently hashing to consumers via a message queue?

I have a producer that I want to distribute work consistently across consumers by consistent hashing. For example, with consumer nodes X and Y, tasks A, B, C should always go to consumer X, and D, E, ...
вопрос задан: 23 May 2017 12:30
0
ответов

Hibernate / Spring: Ошибка при загрузке ленивой коллекции в @Transactional

Хотя я понял ленивую / нетерпеливую загрузку, но, очевидно, нет: у меня есть служба, отмеченная @Transactional, но когда я пытаюсь манипулировать списком, который я получаю (доступ к его объектам), t найти какое-либо расширение dll для php. Мой коллега н
вопрос задан: 23 May 2017 12:22
0
ответов

Уникальные сообщения на очередь в AMQP?

Это подобно этому другому вопросу, но с чем-то вроде скручивания: Я читал в спецификации, что идентификатор сообщения для сообщений AMQP должен быть установлен самим приложением, таким образом, в теории я мог использовать...
вопрос задан: 23 May 2017 12:17
0
ответов

Неустранимая ошибка PHP: класс AMQPConnection не найден

Я уже видел этот вопрос. Это говорит о том, что расширение AMQP PECL не установлено. Однако я успешно установил RabbitMQ и встроенное расширение PECL AMQP. Ниже приводится ...
вопрос задан: 23 May 2017 12:07
0
ответов

Вычисление потока данных в python

У меня есть n (обычно n <10, но он должен масштабироваться) процессов, запущенных на разных машинах и обменивающихся данными через amqp с использованием RabbitMQ. Процессы обычно выполняются долго и могут быть реализованы ...
вопрос задан: 23 May 2017 11:45
0
ответов

когда умирает канал AMQP / RabbitMQ без подключений?

У меня есть простая тестовая программа RabbitMQ, которая случайным образом помещает сообщения в очередь, а другая читает их, все с использованием Spring-AMQP. Если потребитель умирает (например, убивает процесс, не имея возможности закрыть ...
вопрос задан: 23 May 2017 10:33
0
ответов

Спецтестирование EventMachine -на основе (Reactor )Код

Я пробую весь подход BDD и хотел бы протестировать основанный на AMQP -аспект ванильного приложения Ruby, которое я пишу. После выбора Minitest в качестве тестовой среды из-за баланса функций...
вопрос задан: 23 May 2017 10:09
0
ответов

RabbitMQ: постоянное сообщение с обменом темами

Я новичок в RabbitMQ. Я установил «тематический» обмен. Потребители могут быть запущены после издателя. Я бы хотел, чтобы потребители могли получать отправленные сообщения, прежде чем они…
вопрос задан: 10 June 2016 15:16
0
ответов

Когда объявлять / связывать очереди и обмены с RabbitMQ

У меня на рабочем месте есть библиотека-оболочка вокруг RabbitMQ, созданная кем-то, кто больше здесь не работает. Я разрабатываю новую систему с использованием Rabbit и разрабатываю лучший подход для декларирования ...
вопрос задан: 17 February 2016 00:11
0
ответов

Как передать асинхронную функцию в канал amqplib

Мой код nodejs, использующий amqplib, практически идентичен примеру recieve_logs_topic.js. Он читает из очереди RabbitMQ и затем обрабатывает ее. Функцией обработки в этом примере является logMessage (), ...
вопрос задан: 24 February 2015 17:44
0
ответов

django-celery без сервера amqp (rabbitmq)

Я использую сельдерей для обработки распределенных задач. Я хотел развернуть свою работу на веб-хостинге, просто чтобы показать, как работает мой проект. Итак, как я могу заставить djcelery использовать базу данных (sqlalchemy) в качестве бэкэнда ...
вопрос задан: 6 November 2014 12:09
0
ответов

REST API для rabbitmq

Есть ли способ отправить данные в RabbitMQ из $.ajax? Мое приложение состоит из нескольких тысяч веб-клиентов (, написанных на js)и сервисе WCF REST, и теперь я пытаюсь понять, как я могу...
вопрос задан: 6 November 2014 12:00
0
ответов

Lite Python AMQP server implementation for dev and mock?

In Django, running ./manage.py runserver is really nice for dev, avoiding the hassle to setup and start a real webserver. If you are not running Django, you can still setup a gunicorn server very ...
вопрос задан: 6 November 2014 11:58
0
ответов

RabbitMQ сообщения о переупорядочении

RabbitMQ отмечает все поля для проекта, который я планирую, за исключением одного. У меня были бы разные рабочие, которые слушали бы очередь, и важно, чтобы они обрабатывали самые новые сообщения (т.е. последние ...
вопрос задан: 4 June 2014 21:57
0
ответов

RabbitMQ и авторизация

Один из моих проектов требует аутентификации для использования RabbitMQ. Только аутентифицированные пользователи могут подключаться к серверу rabbitmq и подписываться на очереди и т. Д. Например, когда пользователь подключается к серверу ...
вопрос задан: 18 March 2014 18:46