Вопросы по теме 'spring-rabbit'

Spring Rabbit не позволяет переопределять значения по умолчанию в конфигурации фабрики кеширования соединений: выпуск 1.1.4
Я пробую приложение Spring amqp для отправки данных JSON в виде сообщений потребителю (написано на Ruby). Я получаю ошибки сброса подключения при любых настройках, которые я пытаюсь ПРИМЕЧАНИЕ. Я удалил гостя по умолчанию и добавил...
5960 просмотров
schedule 12.10.2023

Исключения Spring AMQP
Это мой первый вопрос в stackoverflow. Я работаю в проекте, который включает Spring AMQP. Для разработки я нашел этот учебник: Пример Spring AMQP Когда я запускаю класс ListenerContainer, я получаю следующее исключение: Вызвано:...
476 просмотров
schedule 18.04.2023

Публикация транзакций Spring-AMQP без исключения
Я пытаюсь использовать канал Transactionnal RabbitMQ с Spring-AMQP, но я хочу фактически проглотить исключения, чтобы регистрировать их и иметь возможность их восстанавливать. Использование channelTranscted = true заставляет канал также...
502 просмотров

нет фиксированного порядка доставки сообщений на сервер Rabbitmq в многопоточной среде
пожалуйста, сначала посмотрите на мой код. Это мой тестовый класс , который создает 2000 потоков , и эти потоки отправляют сообщения. public class MessageSenderMultipleThreadMock { @Autowired MessageList message; @Autowired...
447 просмотров

Spring RabbitTemplate - как получить опубликованное сообщение для NACK в режиме подтверждения издателя
У меня есть веб-приложение, которое публикует сообщения на RabbitQueue с помощью spring. Я включил подтверждение издателя и включил возврат, и я использую шаблон spring rabbit: template. Это моя конфигурация: <rabbit:template...
1527 просмотров
schedule 09.03.2024

Spring Rabbitlistner перестает слушать очередь, используя синтаксис аннотаций
Мы с коллегой работаем над приложением, использующим Spring, которому необходимо получить сообщение из очереди RabbitMQ. Идея состоит в том, чтобы сделать это с помощью (обычно превосходной) системы пружинных аннотаций, чтобы упростить понимание...
4571 просмотров

Как запретить Spring AMQP блокировать незапакованные сообщения?
У меня есть _ 1_ аннотированный метод, для которого Spring AMQP блокируется после возврата из метода. Базовая ссылка _ 2_ использует _ 3_ . Я пока не хочу подтверждать сообщение в методе слушателя. Есть ли способ избежать блока Spring AMQP в...
968 просмотров
schedule 19.11.2022

Spring-Boot отключает загрузку при запуске RabbitMQ
Почему RabbitMQ запускается или запускается при создании jar-файла spring-boot. При запуске Application.java или pom.xml. я могу видеть следующие регистраторы 2016-07-01 16:40:04.334 INFO 7004 --- [ main] com.rabbit.App...
5642 просмотров
schedule 15.08.2023

Spring AMQP - отправитель и получение сообщений
Я столкнулся с проблемой при получении сообщения от RabbitMQ. Я отправляю сообщение, как показано ниже HashMap<Object, Object> senderMap=new HashMap<>(); senderMap.put("STATUS", "SUCCESS");...
10719 просмотров
schedule 08.05.2023

Прочитайте сообщение только счетное количество раз в Spring AMQP
У меня есть приложение, которое получает сообщение от RabbitMQ. После того, как сообщение будет использовано и возникнет какая-либо проблема. Я установил setDefaultRequeueRejected на true , и он снова ставится в очередь. Теперь у меня есть...
220 просмотров
schedule 28.07.2023

В чем разница между подсчетом предварительной выборки и отсутствием подтверждения в rabbitmq
Мне нужно знать, в чем разница между подсчетом предварительной выборки и отсутствием подтверждения в rabbitmq? Также в чем разница между следующими утверждениями: - если я установлю счетчик предварительной выборки, скажем, 10, будет ли создано...
2978 просмотров
schedule 15.05.2023

Как использовать несколько виртуальных хостов в проекте Spring RabbitMQ?
Имеются следующие два класса конфигурации : @Configuration @EnableRabbit @Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class }) public class RabbitConfigA { @Autowired @Qualifier("rabbitConnectionFactory_A") private...
4044 просмотров

spring-amqp работает неправильно, когда соединения заблокированы
Я использую spring-amqp 1.4.4, и после того, как очередь содержит слишком много сообщений и превышает память водяного знака, метод получения RabbitTemplate не отвечает, если он был вызван после метода отправки. Это ждать бесконечно. И в весеннем xml...
872 просмотров

Исчерпанные сообщения в Spring XD с RabbitMQ в качестве шины сообщений
У меня есть установка Spring XD 1.2.0 с одним сервером и парой контейнеров, использующих RabbitMQ в качестве шины сообщений, и я вижу в журналах множество сообщений WARN, таких как эти: 2017-02-05T22:51:03+0100 1.2.0.RELEASE WARN...
121 просмотров
schedule 18.12.2022

Spring-boot-starter RabbitMQ глобальная обработка ошибок
Я использую spring-boot-starter-amqp 1.4.2. Производитель и потребитель работают нормально, но иногда входящие сообщения JSON имеют неправильный синтаксис. Это приводит к следующему (правильному) исключению:...
14897 просмотров

Как избежать отключения SimpleMessageListenerContainer в случае непредвиденных ошибок?
Я использую Java boot 1.4.0 и spring-boot-starter-amqp для подключения к rabbitMq. Производитель сообщений, потребитель и сервер rabbitMq находятся под моим контролем. В течение нескольких месяцев все работало нормально. Но вдруг мой потребитель...
3544 просмотров
schedule 11.05.2023

Как справиться с сообщением JSON с помощью Spring-Rabbit в приложении Spring Boot?
Вот мои фрагменты кода. MQConfiguration класс для конфигурации @Configuration public class MQConfiguration { @Bean public Receiver receiver() { return new Receiver(); } } Receiver класс для работы с получением...
14064 просмотров

Spring boot rabbitMQ DLE не принимает никаких сообщений
Я работаю над rabbitMQ с пружинной загрузкой. Я создаю очередь недоставленных писем, которую я могу видеть в администраторе RabbitMQ как «D, DLE», но, возможно, нет DLK, мне не хватает настройки «x-dead-letter-routing-key», дело в том, что я не...
1161 просмотров

SpringAMQP RabbitMQ, как отправить напрямую в очередь без Exchange
Я использую SpringAMQP с шаблоном Rabbit. Как отправлять сообщения напрямую в очереди, минуя Exchange? Как мне это сделать?
4805 просмотров

Несколько потребителей RabbitMQ для одной очереди
Можно ли отправить сообщение в очередь, используя тему, и иметь 2 получателя, которые будут получать и обрабатывать одно и то же сообщение? В настоящее время я создал 2 потребителя, которые наблюдают за привязкой очереди к теме обмена, но первый...
6026 просмотров
schedule 22.03.2022