Вопросы по теме 'rabbitmq-exchange'

Как отправить отложенное сообщение в rabbitmq с помощью плагина rabbitmq-delayed-message-exchange?
я включил плагин, используя rabbitmq-plugins enable rabbitmq_delayed_message_exchange Я пытаюсь создать отложенный обмен и прикрепленный заголовок x-delay с 5000 мс в качестве значения int и привязал его к очереди, в которой он работает....
1362 просмотров
schedule 21.10.2021

Как аутентифицировать rabbitmq в nodejs?
Ошибка: рукопожатие прервано сервером: 403 (ACCESS-REFUSED) с сообщением «ACCESS_REFUSED - вход в систему был отклонен с использованием механизма аутентификации PLAIN. Подробности см. В файле журнала брокера». Я пробовал authMechanism индивидуально...
1235 просмотров
schedule 19.11.2021

Разрешить RabbitMQ и Pika поддерживать соединение всегда открытым
У меня есть сценарий Python, который считывает данные из потока, и когда новая строка считывается, она помещает ее содержимое (строку) в очередь RabbitMQ. Дело в том, что поток может не отправлять сообщения за 1, 2 или 9 часов или около того,...
2689 просмотров
schedule 18.11.2021

Гарантирует ли RabbitMQ порядок доставки клиенту подтверждений опубликованных сообщений?
Для издателей, отправивших метод confirm.select , буквальное прочтение брокера RabbitMQ документация предполагает, что ответы с подтверждением сообщений могут быть получены клиентом в порядке, отличном от порядка публикации исходных сообщений....
500 просмотров
schedule 18.02.2022

Публикация сообщения с использованием ключа обмена и маршрутизации с помощью MassTransit
Я смотрю на MassTransit уже пару недель, и мне интересно узнать о возможностях. Однако, похоже, я не могу правильно понять концепции. Ожидаемое поведение . Я хотел опубликовать сообщение для «прямого» обмена с ключом маршрутизации, который...
9091 просмотров

Зеркальные очереди RabbitMQ в нескольких кластерах
Можно ли использовать RabbitMQ HA, используя несколько (2) кластеров RabbitMQ? Вот мое требование: У нас есть 2 кластера RabbitMQ (каждый по 4 узла). Все узлы в обоих кластерах будут использовать один и тот же файл cookie Erlang. Таким...
801 просмотров
schedule 24.03.2022

Структура RabbitMQ для обмена личными сообщениями
В настоящее время я ищу создание службы обмена сообщениями, где пользователи могут отправлять и получать сообщения в частном порядке между собой. У меня может быть потребность в многопользовательском чате, но по большей части я хочу, чтобы только...
804 просмотров

Как сгруппировать потребителей в RabbitMQ?
Мы пишем систему синхронизации почты, и для этого используем RabbitMQ. Каждый производитель отправляет идентификаторы писем, затем потребитель получает идентификаторы и вставляет письма в базу данных. В ситуации, когда у нас есть 100 потребителей...
2730 просмотров

RabbitMQ Consumer не получает сообщения, отправленные от производителя
Привет, я пытаюсь отправить сообщение через rabbitMQ. Я объявляю прямой обмен и направляю его в свою очередь на стороне производителя, но я не могу получить сообщение у своего потребителя. Ниже приведен код моего потребителя: package...
3674 просмотров

Ограничение памяти установлено на 819 МБ из 4095 МБ всего - RabbitMQ - Как установить set_vm_memory_high_watermark
Моя служба rabbitMQ падает, как только я ее запускаю. Служба работала нормально последние два года, но внезапно перестала работать. Я посмотрел лог и увидел это: =INFO REPORT==== 8-Oct-2015::11:40:56 === Starting RabbitMQ 3.0.2 on Erlang R16B...
1012 просмотров
schedule 28.05.2022

хочу очистить очередь на удаленной машине rabbitmq
У меня есть rabbitmq, работающий на другом компьютере с IP-адресом 10.8.11.12 на порту 15672, и в нем у меня есть очередь с именем «привет». Я хочу очистить очередь приветствий с моей машины, используя CLI (интерфейс командной строки) Я попытался...
498 просмотров

Как настроить очередь rabbitmq через марионетку
Я пытаюсь установить rabbitmq через puppet. Я использую модуль puppetlabs-rabbitmq . В нем также есть раздел для настройки очередей и обменов, которые Native Types . Я не могу понять, как использовать эти нативные типы. Мой код для установки...
1787 просмотров
schedule 07.09.2022

В RabbitMQ обмен по умолчанию не работает 'COMMAND_INVALID - неверный тип обмена'''
Я изучаю RabbitMQ с помощью учебника https://www.rabbitmq.com/tutorials/tutorial-six-php.html . Я скопировал код из примера. Но я получаю исключение, когда запускаю этот пример . COMMAND_INVALID - invalid exchange type '' Все предыдущие...
156 просмотров
schedule 26.09.2022

Каковы лимиты сообщений, очередей и обменов?
Какие типы сообщений разрешены (строки, байты, целые числа и т. Д.)? Каков максимальный размер сообщения? Какое максимальное количество очередей и обменов?
76175 просмотров

Доступ к одним и тем же сообщениям для нескольких потребителей RabbitMQ
Требование: 1) Мне нужно получить данные, хранящиеся в базе данных Mongo, через Java-приложение и, используя обмен темами и ключи привязки, создать 3 очереди на RabbitMQ. Я реализовал все до этого момента. Проблема начинается со 2-го пункта и...
554 просмотров

Получить все сообщения в очереди RabbitMQ как csv или excel
У меня есть около 10000 сообщений в моей очереди RabbitMq в состоянии готовности. Я думаю об очистке сообщений, но перед очисткой мне нужно загрузить все детали сообщения в виде CSV или Excel для целей резервного копирования. Есть ли способ...
1581 просмотров
schedule 22.11.2022

Варианты балансировки нагрузки с Rabbit MQ
Какие параметры доступны в rabbitMQ для балансировки нагрузки. Я уже прочитал статью http://insidethecpu.com/2014/11/17/load-balancing-a-rabbitmq-cluster/ . Есть ли альтернативный способ? У нас есть только одна очередь, которая отражает ч / б два...
1746 просмотров

Отказ потребителя Rabbitmq
В настоящее время я использую Rabbitmq, я хочу, чтобы 2 потребителя слушали одну и ту же очередь. Но пусть только один потребитель уведомляет о новом сообщении, а другой — о переходе на другой ресурс в случае первого сбоя. Как я могу сделать ?
113 просмотров
schedule 16.03.2023

EasyNetQ публиковать и использовать
Я новичок в EasyNetQ и RabbitMQ. К сожалению, у меня проблемы с потреблением сообщений, и я не уверен, что это из-за того, что я делаю публикацию неправильно, или мое потребление неверно. Я вижу, публикуя, он отправляет в очередь, а потребляя,...
1839 просмотров
schedule 20.06.2023

Встроенная фильтрация сообщений Grails RabbitMQ для потребителя
Я использую версию grails 3.2.3 и версию rabbitmq native plugin 3.3.2 ( http://budjb.github.io/grails-rabbitmq-native/doc/manual/ ). Я пытаюсь реализовать следующий сценарий. Описание: я отправляю несколько сообщений в одну очередь с...
464 просмотров