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

Мой вопрос очень похож на этот: Прием и запрос RabbitTemplate К сожалению, он был отмечен как ответ хотя ответ не соответствует моим потребностям. Я хочу имитировать функциональность пользовательского интерфейса Rabbit Admin, т.е. я хочу...

Каково поведение при использовании следующей конструкции (последняя версия Spring). Я не могу найти его в документации. @RabbitListener(queues = {"q1", "q2", "q3"}) public class MyListener { В каком порядке обрабатываются сообщения из трех...

Я пытался найти способ установить механизм повтора для всех @RabbitListener . Я уже пробовал со свойствами: listener: auto-startup: true concurrency: 1 max-concurrency: 1 retry: enabled: true initial-interval: 1000...

В настоящее время у меня есть аннотация слушателя кролика, установленная как: @RabbitListener (очереди = "моя очередь") Нельзя ли вытащить имя очереди из моего файла yaml. Причина, по которой я хочу это сделать, заключается в том, что я могу...

Я хотел бы генерировать ответы в своей очереди с типом контента application/json, потому что полезная нагрузка содержит объект json. Но... Не знаю, почему мой spring-stream (на основе RabbitMQ) всегда генерирует сообщение с заголовками ниже...

Я пытаюсь использовать Spring AMQP версии 2.1.2.release для создания нескольких привязок к обмену темами. Я нашел этот вопрос: Как настроить несколько тем в классе конфигурации RabbitMQ Java с помощью Spring Framework? Который, казалось, имел...

У меня есть код интеграции Spring, который подключает слушателя JMS (который слушает локальную очередь серии mq) <int-jms:message-driven-channel-adapter> и пересылает сообщение rabbitmq (не контролируемому мной) через...

Я создаю систему массовой обработки видео с помощью spring -boot. Здесь пользователь предоставит всю информацию, относящуюся к видео, через лист xlsx, а мы обработаем видео в бэкэнде. Я использую Rabbitmq для постановки запроса в очередь. Допустим,...

Существует множество примеров, когда java-код используется для настройки чистого кролика, но документация, связанная с загрузкой Spring, - это совсем другая история. Мое требование довольно простое - одна очередь, один обмен, одна очередь...

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

На низком уровне, в чем разница между счетчиком предварительной выборки и размером партии (пакетная обработка) или как они связаны? Чтобы выразить это по-другому, влияет ли одно значение на другое? Кроме того, есть ли способ получить все...

Я настроил dlq и dlx, но сообщение об ошибке не перенаправляет на dlq. Я пытаюсь отправить сообщение из java-приложения, а также с сервера rabbitmq в MESSAGES.EXCHANGE, в обоих случаях я получаю сообщение, но после выдачи сообщения об исключении...

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

Мы пытаемся понять, как Srping Boot ведет себя в сервисе, который ОБЕИМ а) извлекает события из очереди кроликов б) предоставляет пользовательский интерфейс с помощью REST API Проблема в том, что мы хотели бы, чтобы Spring Boot был настроен таким...