Вопросы по теме 'amqp'
DDS против AMQP против ZeroMQ
Я хотел узнать, верны ли мои оценки и опасения.
Я некоторое время изучал три из них: службу распределения данных, AMQP и ZeroMQ для создания уровня передачи данных в центре обработки данных. Все три выглядят многообещающе, но у некоторых я...
9706 просмотров
schedule
21.07.2023
Сельдерей Джанго дает мне (13, «Отказано в доступе»)
Я использую сельдерей django в одном из своих проектов и получаю сообщение об ошибке (13, разрешение запрещено).
Смотрите ниже трассировку:
/usr/lib/python2.4/site-packages/django/core/handlers/base.py in get_response...
1538 просмотров
schedule
02.08.2022
Как использовать AMQP с Apache Camel и Apache CXF?
Приветствую всех. В этом примере я использую Apache Camel и Apache CXF:
http://camel.apache.org/better-jms-transport-for-cxf-webservice-using-apache-camel.data/cxfcamelexample.zip
и я хочу использовать AMQP вместо JMS, но я не знаю...
2878 просмотров
schedule
21.11.2022
Ruby EventMachine + AMQP: обеспечение выполнения определенных асинхронных вызовов до возникновения исключений
Мы создаем систему обмена сообщениями на основе AMQP на Ruby. Однако у нас есть проблема с обработкой ошибок.
Мы поддерживаем белый список исключений, которые являются безопасными, и сообщение в RabbitMQ может быть оставлено неподтвержденным и...
825 просмотров
schedule
14.05.2023
Используя RabbitMQ, есть ли способ просмотреть содержимое очереди без операции удаления из очереди?
В качестве способа изучения RabbitMQ и python я работаю над проектом, который позволяет мне распределять кодировку h264 между несколькими компьютерами. Основы выполнены, у меня есть демон, работающий на Linux или Mac, который подключается к очереди,...
23434 просмотров
schedule
09.02.2023
Как Python может определить, что мой пароль RabbitMQ не удалось?
Я пытаюсь написать приложение Python, использующее RabbitMQ, с помощью библиотеки Pika . Я использую последнюю версию 0.9.5. Моя проблема в том, что мой код Python не может определить, когда его имя пользователя и пароль RabbitMQ неверны, потому...
1749 просмотров
schedule
09.02.2024
Ошибка сборки сервера rabbitmq
Я собираю сервер rabbitmq на Ubuntu (2.6.35-28-generic-pae # 50-Ubuntu SMP, пятница, 18 марта, 20:43:15 UTC 2011 i686 GNU/Linux)
Я использую erlang OPT версии otp_src_R14B03. Я получаю следующую ошибку при построении
erlc -I include -o ebin...
352 просмотров
schedule
17.01.2024
Автоматическое переподключение Rabbitmq pika
У меня есть несколько скриптов, использующих pika.SelectConnection для связи с сервером RabbitMq.
Можно ли как-то заставить эти скрипты автоматически переподключаться к серверу rmq в случае, если сервер вышел из строя, пока скрипт работает?
1616 просмотров
schedule
08.02.2023
RabbitMQ/Pika — гарантия получения сообщений в том порядке, в котором они были созданы?
В качестве простого примера я добавляю 5 элементов в новую очередь RabbitMQ (v 2.6.1):
import pika
connection = pika.BlockingConnection(pika.ConnectionParameters(host='not.my.real.server.net'))
channel = connection.channel()...
3029 просмотров
schedule
12.05.2023
Как я могу оставить соединение AMQP открытым при использовании Ruby-Amqp?
Я использую RabbitMQ и ruby-amqp с Rails. Когда сообщение получено контроллером, я выполняю следующее:
def create
AMQP.start("amqp://localhost:5672") do |connection|
channel = AMQP::Channel.new(connection)
exchange =...
1224 просмотров
schedule
14.10.2022
Отправка результатов из очереди RabbitMQ в интерфейс CakePHP
Я разрабатываю систему, состоящую из внешнего интерфейса, построенного на платформе CakePHP, и внутреннего интерфейса на основе Java. Связь между этими двумя экосистемами осуществляется путем отправки сообщений JSON от контроллера CakePHP брокеру...
1240 просмотров
schedule
24.03.2023
Использование AMQP с графитом 9.9
Я пытаюсь подключить RabbitMQ к Graphite с помощью AMQP, встроенного в Graphite. Однако, когда я раскомментирую настройку в carbon.conf , я получаю:
notroot@ubuntu:/opt/graphite/bin$ sudo python carbon-cache.py start
Starting carbon-cache...
2324 просмотров
schedule
14.04.2024
Различия между AMQP и ZeroMQ
Недавно начал изучать эти технологии AMQP (RabbitMQ, ActiveMQ) и ZeroMQ, интересуясь распределенными системами/вычислениями. Был в Google и StackOverflow, не смог найти определенного сравнения между ними.
Самое большее, что я понял, это то, что...
15200 просмотров
schedule
06.06.2023
Проблемы с обменом фан-аутом RabbitMQ
Я могу создать разветвленную биржу с помощью публикации / подписки RabbitMQ Java учебник, и любой подключенный потребитель получит копию сообщения. Вместо того, чтобы объявлять обмен и привязку динамически / программно, я хотел бы создать обмен и...
6278 просмотров
schedule
08.05.2024
node-amqp не может отправить сообщение RabbitMQ
Я использую rabbitmq-tutorials , версия ruby работает нормально, но версия node.js не может отправить сообщение . Я не знаю, что не так.
var amqp = require('amqp');
var amqp_hacks = require('./amqp-hacks');
var connection =...
2936 просмотров
schedule
28.11.2023
AMQP — сколько потребителей в очереди?
Используя модуль AMQP для Node JS и RabbitMQ, есть ли способ узнать, сколько подписчиков в очереди?
У нас есть несколько очередей на бирже по умолчанию для нескольких регионов. Когда один регион не работает, вместо того, чтобы направлять сообщения...
932 просмотров
schedule
26.04.2022
JMS Подключение к очереди без какой-либо конкретной библиотеки
Я хочу создать класс, который отправляет сообщение в очередь сообщений с использованием протокола AMQP, такого как ActiveMQ или RabbitMQ, но без включения какой-либо конкретной банки/файла/библиотеки для этих поставщиков MQ.
Каждый пример, который...
564 просмотров
schedule
30.08.2023
Можно ли перемещать/объединять сообщения между очередями RabbitMQ?
Я хочу узнать, можно ли перемещать/объединять сообщения из одной очереди в другую. Например:
main-queue содержит сообщения ['cat-1','cat-2','cat-3','cat-4','dog-1','dog-2','cat-5']
dog-queue содержит сообщения ['dog-1, dog-2, dog-3, dog-4]...
13682 просмотров
schedule
30.08.2023
Мул и Кролик AMQP - пытаюсь отправить на обмен
В моем приложении мула я пытаюсь отправить сообщение (xml) на биржу Rabbit MQ. В моем приложении я определил:
<scripting:component doc:name="CreateXML">
<scripting:script engine="Groovy"><