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

Я новичок в RabbitMq. Мы оцениваем его для использования в производстве с приложением rails, в настоящее время для системы фоновой рассылки. Учебник RabbitMq представляет гем bunny . В списке других жемчужин также есть кроссовки . Было бы...

Есть ли способ временно приостановить работу потребителя и возобновить его позже? Вот пример того, что я хочу сделать: require "bunny" conn = Bunny.new conn.start ch1 = conn.create_channel publisher = ch.direct('test', :auto_delete =>...

Я использую Ruby-клиент Rabbit MQ (Bunny). Я переместил конфиг Bunny и процесс инициализации в файл initializer. Как я могу получить доступ к каналам/очередям, открытым в соединении Bunny, изнутри контроллера или библиотеки? Я получаю...

Я пытаюсь проверить функциональность RabbitMQ и Bunny в моей локальной среде в качестве доказательства концепции. В настоящее время мы используем Beaneater/Beanstalk и хотим измениться. Я использую vagrant для своей локальной среды, но не могу найти...

У меня есть следующая рубиновая функция для подключения к существующей очереди кроликов со значением max_length 10000 def self.send(settings, event_str) conn = Bunny.new( hostname: settings['host'], username:...

Я обрабатываю записи из моего rabbitMQ. чтобы избежать потери сообщений от rabbitMQ, я использую стратегию подтверждения RabbitMQ. В целях тестирования я вызвал исключение непосредственно перед кодом, в котором я дал подтверждение RabbitMQ....

Я настроил RabbitMQ и могу мгновенно публиковать и использовать сообщения с помощью bunny gem из приложения rails. Как мы можем добиться отложенной постановки в очередь с заранее определенным временем задержки для каждого сообщения при публикации на...

У меня есть ruby-скрипт, который использует Bunny Gem для подключения к экземпляру rabbitmq. Скрипт работает какое-то время, но в конце концов умирает из-за ошибки Net::ReadTimeout. E, [2017-08-13T08:48:09.671988 #21351] ERROR --...

Используя Ruby-клиент RabbitMQ "bunny", я хочу, чтобы мой производитель (некоторый код Ruby) отправил сообщение потребителю (работнику, использующему гем "sneakers"), и я хочу, чтобы мой производитель не выполнял ни одной строки своего кода Ruby до...

Я запускаю узел RabbitMQ с включенными плагинами MQTT/WebMQTT. Все настройки плагина MQTT используют конфигурацию по умолчанию. Различные клиенты MQTT отправляют сообщения в каналы MQTT. Имена каналов MQTT имеют формат...

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