Описание тега reactor-rabbitmq
0
ответов
Является ли реактор-кролик потокобезопасным
Я планирую использовать клиент RabbitMQ из https://projectreactor.io/ в моем проекте Java. Но из документации ( https://projectreactor.io/docs/rabbitmq/milestone/reference) не ясно, что Отправитель или Получатель является поточно-ориентированным. Мо…
06 ноя '18 в 16:33
1
ответ
RabbitMQ + Reactor, отправляющий ACK после передачи сообщения?
Я пытаюсь выяснить, является ли Project-Reactor приемлемым вариантом для моего варианта использования. Мне нужна высокая согласованность в моем приложении, я хочу: Получить сообщение от RabbitMQ Сделать некоторые манипуляции / преобразование Помести…
17 янв '19 в 07:56
0
ответов
Reactor rabbitmq AlreadyClosedException
В моем проекте я использую Springboot версии 2.1.2.RELEASE, реактор-rabbitmq версии 1.0.0.RELEASE. Я создаю кролика, подписываюсь и обрабатываю сообщения вручную. Но через какое-то время это может быть через час или после 1-2 дней работы, я получаю …
05 фев '19 в 16:13
0
ответов
Reactor RabbitMQ Потребитель "rabbitmq-nio" java.lang.OutOfMemoryError: пространство кучи Java
Я реализую Java-приложение с весенней загрузкой, которое потребляет много маленьких (<5 КБ) json-сообщений. В настоящее время я сталкиваюсь со следующей проблемой в нашей развернутой среде. "rabbitmq-nio" java.lang.OutOfMemoryError: пространство куч…
07 фев '19 в 21:25
0
ответов
sse не отправляет все сообщения
Я использую spring boot 2.0.4 а также reactor-netty а также reactor-rabbitmq-1.0.0.M2 Для реализации простого сервера SSE. По какой-то причине, как клиент, я не получаю все отправленные сообщения. Пример реализации: @RestController @RequestMapping("…
06 авг '18 в 15:30
0
ответов
RPC-клиент с Reactor RabbitMQ - прямой ответ
Я использовал Reactor RabbitMQ для создания Reactive Programming с RabbitMQ. Моя проблема в том, как клиент получает сообщение, когда запрос получен и обработан получателем. Я прочитал о документе RPC Reactor RabbitMQ ( http://projectreactor.io/docs…
22 авг '18 в 02:33
1
ответ
Реактивное программирование с Reactor и RabbitMQ
Недавно я написал демонстрационную программу для запуска реактивного программирования с комбинацией Reactor и RabbitMQ. Это мой демонстрационный код: public class FluxWithRabbitMQDemo { private static final String QUEUE = "demo_thong"; private final…
21 авг '18 в 09:05
0
ответов
Клиент зависает при отправке сообщений RabbitMQ с помощью Java-клиента
Я реализовал издателя и потребителя RabbitMQ в реактивной манере с Java, но мои функции публикации зависают от канала. Сама очередь, объявляя очередь и потребляя, однако, работает нормально, я тестировал ее с помощью пользовательского интерфейса упр…
01 сен '20 в 13:50
1
ответ
Как работать с очередями недоставленных писем с реактором rabbitmq
В нашем приложении мы переходим от spring-amqp к Reaction-rabbitmq, чтобы хорошо работать с реактивным характером приложения. Мы читали официальное руководство от проекта реактор. Однако я не совсем уверен, как отправлять сообщения в очереди недоста…
30 ноя '20 в 08:47