Описание тега amqp-client
0
ответов
Reactor rabbitmq AlreadyClosedException
В моем проекте я использую Springboot версии 2.1.2.RELEASE, реактор-rabbitmq версии 1.0.0.RELEASE. Я создаю кролика, подписываюсь и обрабатываю сообщения вручную. Но через какое-то время это может быть через час или после 1-2 дней работы, я получаю …
05 фев '19 в 16:13
0
ответов
Spring-boot получает сообщение об ошибке "second 'channel.open' visible" в связи с rabbitmq
У меня есть приложение весенней загрузки, использующее версию весенней загрузки 1.5.16.RELEASE, который добавляет следующие зависимости к моему приложению: [INFO] | +- com.rabbitmq:http-client:jar:1.0.0.RELEASE:compile [INFO] | +- org.springframewor…
12 фев '19 в 10:50
1
ответ
Временно прекратить использование сообщений RabbitMQ и возобновить позже
Я использую Rabbitmq-клиент Java ( https://mvnrepository.com/artifact/com.rabbitmq/amqp-client), и мне нужно реализовать следующий сценарий: При получении сообщений Rabbit мне может потребоваться приостановить потребление Rabbitmq из определенных оч…
30 дек '17 в 10:38
0
ответов
Почему происходит сбой подключения к локальному RabbitMQ с помощью amqp-клиента на недоступном DNS-сервере
Существует один локальный экземпляр RabbitMQ. Код клиента выглядит следующим образом (с amqp-client-5.2.0): ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); Connection connection = factory.newConnection(); Когда DNS…
23 май '18 в 08:29
1
ответ
Rebar3 & RabbitMQ amqp_client
Обновлено: использование hex вместо git для добавления зависимостей в rebar.config решило проблему. Используйте формат {amqp_client, "3.7.8"}, {rabbit_common, "3.7.8"} Оригинальный вопрос - у меня очень трудное время с интеграцией RabbitMQ amqp_clie…
22 июн '18 в 21:36
0
ответов
Моя простая ошибка клиента Java RabbitMQ: (Сообщение об исключении: сброс соединения)
У меня есть RabbitMQ клиент на Java прослушивает входящие уведомления для их обработки (версия клиента RabbitMQ Java 5.5.1). После нескольких месяцев бесперебойной работы, вчера я вдруг увидел эту ошибку, после которой не было получено ни одного соо…
10 июл '19 в 18:38
0
ответов
AMQP-клиент и JDK 12
Кто-нибудь использовал AMQP-CLIENT (RabbitMQ) с OpenJDK 12? Я попытался и получил ошибку SSL при соединении с TLS1.2. Отлично работает на JDK 8.
28 май '19 в 21:03
0
ответов
Библиотека AMQP-CPP, message.body() возвращает полезную нагрузку с мусором в конце
Я пытаюсь использовать библиотеку AMQP-CPP, и теперь проблема в том, что полученные сообщения содержат некоторую грязь в конце. В wirehark все вроде нормально при просмотре связи ampq. Я пробовал встроенные функции boost и libuv для вызывающих событ…
22 ноя '20 в 14:07
2
ответа
Как мы можем не получить новое сообщение из очереди в Java rabbitmq, пока я не отвечу на сообщение?
Получите одно сообщение из очереди в RabbitMQ, используя java: Я новичок в RabbitMQ и задавался вопросом о хорошем подходе к этой проблеме, над которой я размышляю. Я хочу создать службу, которая подписывается на очередь и получает только одно сообщ…
11 сен '21 в 18:21
0
ответов
make-basic.publish со значением по умолчанию для обмена выдает ошибку исключения: неверный аргумент
Я пытаюсь следовать учебнику RabbitMq hello world в Lisp Flavored Erlang. Учебник предназначен для Elixir, с помощью руководства пользователя клиента Erlang RabbitMQ я пытаюсь перевести шаги в LFE. Чтобы опубликовать сообщение, мне нужен basic.publi…
22 мар '22 в 22:00
0
ответов
Восстановление соединения Cloudamqp amqp-client.js
Я интегрирую ampq-клиент в свое приложение javaScript, но мне интересно, как эта библиотека обеспечивает восстановление в случае сбоев сети. Вариантов восстановления не вижу и после простого теста вроде не восстанавливается. Я хочу спросить: => Е…
06 июн '23 в 12:17