Описание тега amqp
AMQP - это открытый стандарт обмена сообщениями. Он определяет протокол проводного уровня и семантическую структуру для высокопроизводительного обмена сообщениями предприятия. Если вы используете определенного брокера (например, [rabbitmq]), то тег AMQP может быть избыточным. AMQP не следует путать с Apache[ActiveMQ]
1
ответ
RabbitMQ для имитации обмена темами с прямым обменом
Есть ли способ, которым я могу иметь прямой обмен, имитирующий обмен темами (я знаю, что можно получить противоположное: см. Здесь), но мой пример использования здесь заключается в том, что я уже развернул прямой обмен с большим количеством очередей…
23 мар '11 в 10:43
1
ответ
Как заставить очередь Rabbit MQ работать в режиме хранения и пересылки?
Я экспериментирую с Rabbit MQ, используя клиент Python Pika. Я хотел бы, чтобы мой отправитель AMQP работал в режиме хранения и пересылки, т. Е. Иметь возможность начинать очередь сообщений, если сервер или сеть не работает, и надежно доставлять их …
17 авг '14 в 02:21
1
ответ
RabbitMQ Эксклюзивная очередь потерянных сообщений
Для потребителя, при объявлении очереди как "исключительной", очередь будет удалена, когда потребитель отключится в соответствии с документацией. Если в очереди ожидают обработки сообщения и потребитель переходит в автономный режим, все сообщения в …
10 июн '16 в 19:39
1
ответ
RabbitMQ против NoSQL?
Мне просто интересно, почему вы используете что-то вроде RabbitMQ вместо постоянного хранилища, особенно хранилище документов, такого как MongoDB? Они вроде как одинаковые? В чем преимущество RabbitMQ над базой данных? Кто-нибудь, кто использовал чт…
22 июл '15 в 00:19
1
ответ
Flume не может поместить файлы в корзину S3
Я использую Flume в режиме "только для узлов" (тестирование); Flume извлекает сообщения из RabbitMQ и помещает их в корзину Amazon S3. Эта проблема: Flume фактически извлекает данные из RabbitMQ, но файлы не отображаются в корзине S3. Технические де…
16 авг '12 в 12:33
1
ответ
Отправлять и получать сообщения - синхронный режим mqlight
Есть ли способ отправлять и получать сообщения с использованием протокола MQLight "AMQP" в синхронном режиме, а не неблокирующем асинхронном режиме. Если да, приведите пример Все примеры, размещенные здесь " https://developer.ibm.com/messaging/mq-li…
26 сен '15 в 00:23
2
ответа
Как разобрать объект JSON в Spring AMQP?
Существует удаленный сервер RabbitMQ, который позволяет мне только отправлять и получать сообщения. Это значит, что я не могу ничего создать. Я отправляю определенный запрос и получаю ответ в формате JSON. В моем приложении у меня есть простой класс…
03 сен '18 в 09:29
1
ответ
activemq brokerName всегда localhost?
Это может быть вопрос n00b, я установил activemq на CentoOS, и когда я запускаю его так, установите для brokerName значение "Test": sudo activemq start broker:tcp://localhost:61666?brokerName=Test&persistent=true&useJmx=false Затем запросите…
05 июн '13 в 23:45
1
ответ
Распределенные вычисления с использованием очереди сообщений VS Map/Reduce
Контекст: Мы рассматриваем AMQP-совместимое решение как способ вычисления постоянного потока данных, объем которого составляет 90 ГБ в день. То, чего мы хотели бы достичь, это живая статистика, более или менее основанная на всех или некоторой комбин…
02 май '12 в 12:59
1
ответ
Голосовое вещание с несколькими звездочками для большой громкости
Как я могу интегрировать AMQP в Asterisk AMI?
26 сен '16 в 07:51
1
ответ
Сервисная шина Windows - AMQP - Java
Я разрабатываю клиент, который читает сообщение из служебной шины Windows, отправленное с использованием.NET. Клиент разработан с использованием Java и насколько я знаю, он создает сеанс, но когда он добирается до создания, потребители выдают исключ…
02 апр '14 в 21:12
0
ответов
Как равномерно распределить сообщения между разными очередями?
Я хочу изменить созданный мной кластер RabbitMQ. Я хочу иметь один узел, который будет содержать статистику / диск. И я хочу иметь еще два узла, которые будут работать в оперативной памяти. Как создать очередь на каждом сервере и сделать обмен равно…
04 сен '13 в 17:50
1
ответ
Клиент Objective-C RabbitMQ не публикует сообщения в очереди
Я пытаюсь создать приложение для обмена сообщениями, используя RabbitMQ для iOS. и я использую классы-оболочки для цели c, с клиентскими библиотеками RabbitMQ-C. https://github.com/profmaad/librabbitmq-objc Exchange, Queue & Queue Binding все в поря…
17 июл '14 в 04:58
2
ответа
Лучшие практики NodeJS с обещаниями
Я разрабатываю новую библиотеку выше amqp.node (amqplib), в основном нам не нужны все функциональные возможности RabbitMQ. Итак, я создаю простую библиотеку, которая облегчает использование специально для нашего проекта. Эта новая библиотека вернет …
04 авг '15 в 06:32
1
ответ
RabbitMq потребляет по приоритету
Я хочу использовать сообщения из очереди RabbitMq, но только для одного priority, У меня есть объявление приоритета для моей очереди x-max-priority:10и сообщения с приоритетом Exchange exchange.fanout Properties priority: 10 content_type: text/plain…
21 дек '16 в 13:18
2
ответа
Используя RabbitMQ (Java-клиент), есть ли способ определить, закрыто ли сетевое соединение во время потребления?
Я использую RabbitMQ на RHEL 5.3 с помощью клиента Java. У меня 2 узла (машины). Node1 использует сообщения из очереди на Node2, используя вспомогательный класс Java QueueingConsumer. QueueingConsumer consumer = new QueueingConsumer(channel); channe…
18 мар '10 в 18:07
2
ответа
Обещания Javascript /Q - Я делаю это правильно?
Я пытаюсь использовать Q в NodeJS для создания некоторых оберток amqplib. Обертки работают правильно (пока), но я чувствую, что мое использование Q... неправильно. Во-первых, есть метод инициализации: private static Startup(): void { var sub_YoMsgHa…
10 май '14 в 07:26
1
ответ
Несвязанный Fanout Exchange теряет данные
Когда я передаю несколько сообщений на обмен Fanout (который еще не связан ни с какой очередью) и останавливаю издателя, сообщения, отправленные на обмен, теряются. Обмен останавливается. Возможно ли, что несвязанный Exchange может содержать опублик…
06 май '17 в 08:21
1
ответ
Как создать интерфейс командной строки, который может взаимодействовать с постоянно работающим сервисом, похожим на оболочку MySQL?
У меня есть небольшое приложение, которое должно работать в фоновом режиме. Программа может настроить службы мониторинга каталогов, HTTPS-прослушиватели и другие службы, которые должны оставаться работающими как часть основного потока службы. Однако…
12 май '16 в 13:23
1
ответ
Реализация блокирующих сообщений с Rabbitmq (или перехват между издателем и потребителем)
У меня есть 8 потребителей в очереди, и любой из них может получать сообщения и после обработки, это влияет на БД. Большинство сообщений может быть запущено асинхронно, но в некоторых сообщениях нам нужно прекратить использование очереди, пока это с…
10 фев '14 в 14:29